​
StreamNative Weekly Release Notes v4.0.5.5

​
Download

​
Distributions

​
Packages

​
Images

​
General Changes

​
Apache Pulsar

(#24597) [improve][client] RawReader support pause and resume (#24450) [fix][broker] Fix REST API to produce messages to single-partitioned topics (#24570) [fix][broker] Fix NPE being logged if load manager class name is blank (#24593) [fix][broker] Fix incorrect AuthData passed to AuthorizationService in proxy scenarios (#24489) [improve][io] Add support for the complete KinesisProducerConfiguration in KinesisSinkConfig (#24535) [improve][test] Add test for dead letter topic with max unacked messages blocking (#24532) [fix][misc] Upgrade dependencies to fix critical security vulnerabilities (#24542) [fix][broker]Fix thread safety issues in BucketDelayedDeliveryTracker with StampedLock optimistic reads (#24520) [improve][broker] Extract duplication in AbstractTopic#incrementTopicEpochIfNeeded (#24582) [improve][client] Support load RSA PKCS#8 private key (#24591) [fix][broker] Fix namespace deletion TLS URL selection for geo-replication (#24586) [improve][test] Refactor the way way pulsar-io-debezium-oracle nar file is patched when building the test image (#24590) [fix][broker] Fix flaky testReplicatorsInflightTaskListIsEmptyAfterReplicationFinished (#24542))) Revert “[fix][broker]Fix thread safety issues in BucketDelayedDeliveryTracker with StampedLock optimistic reads (#24554) (#24571) [fix][client][branch-4.0] Partitioned topics are unexpectedly created by client after deletion (#24576) [fix][test] fix flaky GrowableArrayBlockingQueueTest.testPollBlockingThreadsTermination (#24569) [fix][broker] Fix ManagedCursor state management race conditions and lifecycle issues (#24550) [improve][client] Terminate consumer.receive() when consumer is closed (#24560) [fix][broker] Fix maxTopicsPerNamespace might report a false failure (#24505) [fix][test]fix flaky test BrokerServiceAutoTopicCreationTest.testDynamicConfigurationTopicAutoCreationPartitioned (#24551) [fix][broker] Fix Broker OOM due to too many waiting cursors and reuse a recycled OpReadEntry incorrectly (#24511) [fix][broker] Fix deduplication replay might never complete for exceptions (#24522) [fix][ml] Fix the possibility of message loss or disorder when ML PayloadProcessor processing fails

​
AoP

Add qpid dependencies

​
MoP

Fix MQTT message error handling and improve connection responses

​
KoP

Do not set setReplicationClusters on createTopicIfNotExist

​
StreamNative Pulsar Plugins

fix export duplicated JVM metrics on AuditLogMetrics

​
Cloud Pulsar Plugins

Only append jwk when kty is rsa

​
Function Mesh Worker Service

467ec4ba Update version when release Implement agent function

​
StreamNative Tiered storage

Fix build failure

​
StreamNative Unified RBAC

[feat] Extend functions&connectors permissions

​
StreamNative Ursa storage

Only publish BlobNotFound exception task to DLQ Exclude OutOfMemoryError for DLQ Support publish commit failed tasks to DLQ Fix oxia lock leak when not acquired Optimize Compaction Service heap memory usage fix[lock]: fixes memory leak on oxia distributed lock Introduce catalog factory for iceberg Add external table protobuf support for Ursa and Pulsar protocol Make the pulsar compaction worker not record column stats. Using bookkeeperStorageApi when configured pulsar client Add compaction leader metric doc Delete committed tasks and update oxia index Fix the error handling Remove unnecessary synchronized lock fix: handle UUID logical type with string base type in AvroToIcebergConverter Fix ConcurrentModificationException in CompactionTaskProvider.getTask Cleanup stream when deleting unloaded topics Add multi catalog user document Add compaction service throguhput rate limiter for reading from BookKeeper Support multiple catalog in namespace and topic level Refactor update iceberg table properties Separate managed and external writer for ursa Add compaction leader metric Add failure reason for the iceberg external writer Optimize reset cursor

​
Security Fixes

​
Apache Pulsar

(#24562) [fix][sec] Remove dependency on out-dated commons-configuration 1.x (#24564) [fix][sec] Upgrade Kafka connector and clients version to 3.9.1 to address CVE-2025-27818