Skip to main content

StreamNative Weekly Release Notes v4.2.5.2

Download

Distributions

Packages

Images

General Changes

Apache Pulsar

(#27026) [fix][broker] Retry incompatible replication schemas without topic unload (#21767) [fix][client] Fix message leaks and size and permit accounting races when clearing the consumer’s incoming queue (#27021) [fix][broker] Reset fixed delay detection when the in-memory delayed delivery tracker is cleared (#26845) [fix][meta] Fix repeated metadata recovery failures after a ZooKeeper session expires (#27017) [fix][broker] Don’t continue the REST topic listings that waited for a size estimate one after another on a metadata store thread (#26999) [fix][proxy] Fix Proxy Protocol forwarding for UNKNOWN and IPv6 (#26945) [fix][broker] Fix topic listing memory limit enforcement (#27011) [improve][doc] Warn about /tmp cleanup in narExtractionDirectory docs (#27007) [fix][broker] Don’t dispatch a replay read that was pending when all consumers of a Shared subscription disconnected (#27005) [improve][ml] Don’t visit a ledger’s other single-entry pending reads for a read of a single entry (#26701) [fix][broker] Fix spurious placement failures when IsolatedBookieEnsemblePlacementPolicy counts unavailable secondary bookies (#26991) [fix][broker] Fence non-persistent subscriptions before asynchronous … (#26976) [fix][broker] Remove the sticky key hashes of a sparse replay prefix when the mark-delete position moves (#24912) [fix][broker] Fix partitioned topic auto deletion http request timeout (#26962) [fix][broker] Use the uncompressed payload when finding the last message position of a compacted batch (#24793) [fix][broker] Producer still publishes messages to Broker after Topic was unloaded (#24974) [fix][client] Fix retry logic for BinaryProtoLookupService.getTopicsUnderNamespace method (#26664) [fix][broker] Prevent stale messages from surviving compaction retries (#26742) [fix][ml] Complete the original future after ledger deletion retries (#26828) [fix][meta] Fix leader election close deleting a leader node owned by another session (#26940) [fix][metadata] Invalidate ledger metadata cache on version conflicts (#25244) [fix][broker] The configuration subscriptionExpirationTimeMinutes does not work if the topic was reloaded frequently (#25259) [fix][broker] Avoid false WARN log when replicator is already terminated (#25766) [BUG] Fix stats in PulsarZooKeeperClient multi. (#25040) [fix][admin] Use ClientConfigurationData timeout params to set AsyncHttpConnector timeout params (#27015) [fix][broker] Fix the broker’s WebSocket service ignoring configurationStoreConfigPath (#26978) [improve][meta] Log metadata store deletes at DEBUG (#26946) [improve][broker] Write async REST responses on the web service executor (#26933) [improve][ml] Bound the requeues of size-based cache eviction to one cycle through the removal queue (#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 (#26944) [fix][ml] Serialize a cursor’s reused position info under its monitor (#26672) [fix][client] Schedule TableView tail-read retries instead of sleeping on the callback thread (#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 (#26893) [improve][build] Upgrade LightProto to 0.9.3 (#26881) [fix][client] Don’t retry a Pulsar Admin request after its request timeout has elapsed (#26741) [fix][test] Fix flaky LatencyTracerTest.testTraceFuture (#26666) [improve][broker] trace topic loading latency and timeout states (#26264) [improve][broker] Add reason label for topic_load_failed_total (#26930) [fix][misc] Upgrade jline to avoid cve (#26479) [fix][broker]Incorrect source side topic permission deletion when disabling replication (#26917) [fix][broker] Return retryable error for timed-out end transactions (#26894) [fix][broker] Run the inactive topic GC when it is enabled by dynamic configuration

KoP

[fix] Poll until the expected messages arrive in TransactionTest.readAndCheckMessages 553d1e42c [branch-4.2] Bump sn-bom to 4.2.5.2 [fix] Fix waiting Fetch requests that spin and re-run offset searches [fix] Avoid byte-by-byte copies when decoding Pulsar entries to Kafka records [fix] Fix KopPersistentTopic initialize method

Function Mesh Worker Service

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

Security Fixes

Apache Pulsar

(#27023) [fix][sec] Bump github.com/klauspost/compress from 1.18.0 to 1.18.7 in /pulsar-function-go