Skip to main content

StreamNative Weekly Release Notes v4.2.1.6

Download

Distributions

Packages

Images

General Changes

Apache Pulsar

(#26136) [fix][fn] Reorder Function Worker shutdown to stop scheduler before runtime manager (#26139) [improve][fn] Upgrade pulsar-client-python to 3.13.0 (#26134) [improve][broker] Load topic policies on non-persistent topic load and gate the policy replay (#26123) [fix][test] Run makeReadEntryProbFail’s errorOrNot on a caller-provided executor (#26083) [fix][test] Fix flaky PersistentTopicsTest setup caused by concurrent Mockito stubbing (#26122) [fix][test] Fix flaky AuditorBookieTest.testBookieClusterRestart (#26132) [fix][broker] Don’t let a closing topic-policies reader abort a concurrent cache-init reload (#26106) [fix][broker] Fix replication stall when a cursor rewind skips an in-flight read (#25645) [fix][test] Fix flaky SchemaServiceTest.testSchemaRegistryMetrics (#26110) [fix][broker] Forward topic policy updates after init failures (#26005) [fix][broker] Fix replicator getting stuck under rate limiter throttling and honor readBatchSize/maxReadSizeBytes on the default read path (#26055) [improve][broker] Improve dispatch performance by summing entry bytes with a loop (#26080) [fix][broker] Guard BucketDelayedDeliveryTracker.nextDeliveryTime against empty queues (#25984) [improve][broker] Trim orphaned bucket snapshots when ledgers are deleted (#25915) [fix][broker]Do not trigger topic GC if replication is still active

MoP

cc9fb9cd test: isolate mock ZooKeeper sessions per broker

KoP

Support handling non-partitioned topics for DescribeTopicPartitions and configs 488bc0e87 [branch-4.2] Remove explicit Netty dependencies because they are not included in sn-bom [feature] Refactor JSON schema compatibility checker [branch-4.2] Use sn-bom to manage all dependency versions 29ac2b707 [branch-4.2] Bump TestNG version to 7.12.0 Improve earliest offset query performance by recording start offset in managed ledger properties [fix] lock-ordering deadlock between partitionLock and group lock in storeOffsetMessageAsync

StreamNative Pulsar Plugins

ff575d44c Upgrade the bk version fix: upgrade golang.org/x/net to v0.55.0 to fix multiple CVEs

Function Mesh Worker Service

feat: support session-local agent tool/mcp_servers overrides on session update feat: Align managed agent endpoints feat: use agent id for agent trigger and support agent version Support cron agent triggers in worker service feat: Align managed agent vault API validation [codex] Support Claude memory and file APIs

Pulsar Tiered Storage v2

feat(offloader): configurable GCS/S3 upload tuning feat(gcs): configurable read/upload buffering (fix Old-Gen churn) + parallel composite upload fix(azure): let streamnative-bom manage azure-identity (matches what we ship)

Security Fixes

Apache Pulsar

(#26142) [fix][sec] Bump github.com/go-jose/go-jose/v4 from 4.1.3 to 4.1.4 in /pulsar-function-go (#26140) [fix][sec] Upgrade pulsar-client-go to v0.20.0 in pulsar-function-go, also address CVEs (#26099) [fix][sec][branch-4.2] Upgrade Jackson version to 2.18.8