Skip to main contentStreamNative 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
