StreamNative Weekly Release Notes v3.3.5.14

Download

Distributions

Packages

Images

General Changes

Apache Pulsar

(#24741) [fix][broker] Prevent unexpected recycle failure in dispatcher’s read callback (#24752) [fix][client] rollback TopicListWatcher retry behavior (#24698) [fix][client]TopicListWatcher not closed when calling PatternMultiTopicsConsumerImpl.closeAsync() method (#24634) Dispatcher did unnecessary sort for recentlyJoinedConsumers and printed noisy error logs (#24730) [fix][broker] Ensure KeyShared sticky mode consumer respects assigned ranges (#24743) [fix][client] Fix receiver queue auto-scale without memory limit (#24742) [improve][build] Upgrade Apache Parent POM to version 35 (#24731) [fix][broker] Fix cannot shutdown broker gracefully by admin api (#24654) [fix][io] Improve Kafka Connect source offset flushing logic (#24725) [fix][client] Avoid recycling the same ConcurrentBitSetRecyclable among different threads (#24721) [feat][fn] Fallback to using STATE_STORAGE_SERVICE_URL in PulsarMetadataStateStoreProviderImpl.init (#24719) [fix][broker] Fix memory leak when metrics are updated in a thread other than FastThreadLocalThread (#24594) [improve][build] Disable javadoc build failure (#23336) [fix][client] Fix ArrayIndexOutOfBoundsException when using SameAuthParamsLookupAutoClusterFailover (#24665) [fix][meta] Use getChildrenFromStore to read children data to avoid lost data (#23977) [fix][broker] Invalid regex in PulsarLedgerManager causes zk data notification to be ignored (#24663) [fix][client] Skip schema validation when sending messages to DLQ to avoid infinite loop when schema validation fails on an incoming message (#24669) [improve][io] Support specifying Kinesis KPL native binary path with 1.0 version specific path (#24668) [improve][build] Use org.apache.nifi:nifi-nar-maven-plugin:2.1.0 with skipDocGeneration=true (#24661) [improve][io] Upgrade AWS SDK v1 & v2, Kinesis KPL and KPC versions (#24666) [improve][build] Increase maven resolver’s sync context timeout (#24662) [fix][client] fix ArrayIndexOutOfBoundsException in SameAuthParamsLookupAutoClusterFailover (#24639) [fix][broker] Fix race condition in MetadataStoreCacheLoader causing inconsistent availableBroker list caching (#24649) [fix][offload] Exclude unnecessary dependencies from tiered storage provider / offloader nar files (#24643) [fix][broker] Add double-check for non-durable cursor creation

KoP

6743e673b Bump Pulsar version to 3.3.5.14 Use new CompactedTopicUtils.asyncReadCompactedEntries API from apache/pulsar#24725 [branch-3.3] Add latency metrics for ManagedLedgerImpl#internalAsyncAddEntry Add more info to logs when the connection is closed Handle unexpected exception in decode for safe producer state recovery Avoid blocking when the previous consumer closed without sending SyncGroup requests

StreamNative Pulsar Plugins

[detector] Print more info when a corrupted value is received by Kafka consumer [detector] Enable idempotence for Kafka detector Update x/net and go 1.24

pulsarctl

Preserve tenant fields on partial update upgrade client go version to 0.16.0 Update stable version Upgrade go to 1.24.6 to fix CVE-2025-47907

Function Mesh Worker Service

feat: support multiple mcp servers Support trigger agent function with properties Update function-mesh version to v0.25.0 in pom.xml Remove ConnectRestException from mesh-worker-common module Support input-type-class and output-type-class arguments for Functions Support set extra env for kafka connect Support streamable http for AgentFunction and make trigger timeout value configurable Create a new sub module mesh-worker-common

StreamNative Tiered storage

[Branch 3.3] Cherry pick 1102

StreamNative Unified RBAC

feat: treat NotFound exception as success for deleting feat: upgrade sdk-go version to v0.14.0 feat: support extract variable claim from token

Security Fixes

Apache Pulsar

(#24717) [fix][sec] Upgrade Netty to 4.1.127.Final to address CVEs (#24650) [fix][sec] Upgrade bouncycastle bcpkix-fips version to 1.79 to address CVE-2025-8916