​

StreamNative Weekly Release Notes v4.1.0.3

​

Download

​

Distributions

• https://github.com/streamnative/pulsar/releases/tag/v4.1.0.3

​

Packages

• Maven Central

​

Images

• sn-platform
• sn-platform-slim
• private-cloud

​

General Changes

​

Apache Pulsar

(#24779) Bump org.apache.zookeeper:zookeeper from 3.9.3 to 3.9.4 (#24596) [improve][broker]Call scheduleAtFixedRateNonConcurrently for scheduled tasks, instead of scheduleAtFixedRate (#23386) [improve][broker] PIP-402: Optionally prevent role/originalPrincipal logging (#24772) [fix][misc] Fix compareTo contract violation for NamespaceBundleStats, TimeAverageMessageData and ResourceUnitRanking (#24753) [fix][ml]Fix EOFException after enabled topics offloading (#24769) [fix][test] Flaky-test: BrokerServiceTest.testShutDownWithMaxConcurrentUnload (#24764) [improve][build] Upgrade Mockito, AssertJ and ByteBuddy to fully support JDK25 (#24761) [fix][client] Exclude io.prometheus:simpleclient_caffeine from client-side dependencies (#24763) [improve][build] Upgrade Lombok to 1.18.42 to fully support JDK25 (#23634) [improve][broker] If there is a deadlock in the service, the probe should return a failure because the service may be unavailable (#24738) [fix][broker] First entry will be skipped if opening NonDurableCursor while trimmed ledger is adding first entry. (#24768) [improve][build] Upgrade SpotBugs to a version that supports JDK25 (#24767) [fix][ci] Fix CI for Java 25 including upgrade of Gradle Develocity Maven extension (#24741) [fix][broker] Prevent unexpected recycle failure in dispatcher’s read callback

​

AoP

Fix configuration potential NPE in test

​

KoP

Use new CompactedTopicUtils.asyncReadCompactedEntries API from apache/pulsar#24725

​

StreamNative Pulsar Plugins

[feat][topic-compaction-service] Implement clean expired message during compaction Fix gcs-connector cve

​

Function Mesh Worker Service

Reject request when agent name is too long or sessionId is not valid feat: support multiple mcp servers

​

StreamNative Tiered storage

Yong/test branch 4.1

​

StreamNative Unified RBAC

feat: treat NotFound exception as success for deleting feat: upgrade sdk-go version to v0.14.0 Add conditions for Catalog, CC and CE feat: support extract variable claim from token

​

StreamNative Ursa storage

Fix catalog instance not shared Move the iceberg table creation params to a common place Fix the integration test mount jar issue. fix: mask sensitive properties in CatalogKey toString to avoid credential leaks in logs

​

Security Fixes