Skip to main content

StreamNative Weekly Release Notes v4.0.14.2

Download

Distributions

Packages

Images

General Changes

Apache Pulsar

(#27015) [fix][broker] Fix the broker’s WebSocket service ignoring configurationStoreConfigPath (#26775) [fix][broker] Preserve topic initialization failures (#26666) [improve][broker] trace topic loading latency and timeout states (#26264) [improve][broker] Add reason label for topic_load_failed_total (#26946) [improve][broker] Write async REST responses on the web service executor (#25443) [fix][broker]The partitions of the topic was wrongly created even though this cluster was not allowed to access it (#25282) [fix][misc] Fix Backoff mandatory-stop timer tracking (#26929) [fix][broker] PIP-442: Fix unbounded executor queue growth and single-thread bottleneck in the topic list memory limiter (#26928) [fix][broker] Fix inflated rate stats of newly created consumers (#26550) [fix][client] Make chunking inert on non-persistent topics, including the message-size checks (#26910) [fix][broker] Preserve unacked backpressure for stale redelivery requests (#26084) [fix][client] Serialize chunked-message bookkeeping to fix use-after-free and count/queue drift (#26902) [fix][broker] Clean up orphan schema ledgers after write failures (#26905) [fix][broker] Prevent bundle split hangs on executor rejection (#26907) [fix][broker] Prevent duplicate messages when reconnect races with purge (#26908) [fix][broker] Honor dynamic decreases of dispatcherMaxReadBatchSize (#26912) [fix][client] Release connections on partition metadata rejection (#26765) [fix][managed-ledger] Persist partial batch ACKs on flush (#26909) [fix][client] Prevent chunk message ID leaks after seek (#26818) [fix][schema] Fix BookKeeper read handle leaks on schema read failures (#26063) [fix][ml] Wait for managed ledgers to close on factory shutdown, bounding each close (#26726) [fix][client] Return flow-control permit when client seek by messageID (#26829) [fix][broker] Match namespace isolation policy brokers given as host:port (#26658) [fix] [client] chunked message uuid-queue never removes entries on successful processing (#26108) [fix][broker] Handle synchronous schema lookup failures in replication (#26895) [fix][broker] Fix web service close hang when the Jetty server fails to start (#26652) [fix][broker] Prevent stale consumer removal from removing replacements (#26669) [fix][meta] Return LedgerExistException for duplicate ledger creation (#26725) [fix][schema] Fix Protobuf native descriptor deserialization (#26891) [fix][offload] Fix NPE when reading from a closed offloaded read handle by keeping its ledger metadata (#26881) [fix][client] Don’t retry a Pulsar Admin request after its request timeout has elapsed

KoP

[fix] Avoid byte-by-byte copies when decoding Pulsar entries to Kafka records [test] Fix start offset test assumption about future completion [fix] Fix connection close on unsupported ApiVersions request versions [fix] Fix KopPersistentTopic initialize method

Function Mesh Worker Service

d812dac9 fix build worker-service: Map producer compression types for Functions and Sources

Security Fixes