Skip to main content

​
StreamNative Weekly Release Notes v4.1.0.11

​
Download

​
Distributions

​
Packages

​
Images

​
General Changes

​
Apache Pulsar

(#25105) [fix][broker]pulsar_ml_reads_inflight_bytes and pulsar_ml_reads_available_inflight_bytes are 0 at the same time (#25087) [fix][broker] Fix cursor position persistence in ledger trimming (#25085) [improve][io] Replace Qpid in tests with RabbitMQ in Testcontainers and upgrade RabbitMQ client version (#25084) [fix][build] Activate jdk21 and jdk24 profiles on Java 25

​
MoP

Fix mqtt disconnect due to appId permission bug when namespace policies update

​
KoP

[Ursa] Fix the pulsar internal topic owner issue caused create topic stuck Fix potential NPE issue when initializing schema storage reader Fix inflight reads limiter permits leak when offsetsForTimes is called Return UNKNOWN_TOPIC_OR_PARTITION error for partitioned metadata loss Fix retention and TTL policies on metadata namespace Fix producer state manager snapshot buffer start issue when use global zk Improve logging for read entry errors fix(schemaregistry): add schema type check before compatibility checking fix(schema-registry): validate JSON schema format during registration Remove the immature producer side throttling feature Correct token extraction for Kafka internal schema registry client

​
pulsarctl

Fix assertion on TopiCreateTimeStamp Upgrade pulsar go client to latest and golang to 1.25

​
Function Mesh Worker Service

Uncomment connector copy commands in Dockerfile fix: kafka sink auth inject not working Update authorization error msg build(deps): bump function-mesh.version to v0.26.1

​
Security Fixes

​
Apache Pulsar

(#25102) [fix][sec] Upgrade log4j to 2.25.3 to address CVE-2025-68161 (#25095) [fix][sec] Upgrade jose4j to 0.9.6 to address CVE-2024-29371 (#25078) [fix][sec] Upgrade Netty to 4.1.130.Final