Skip to main content

​
StreamNative Weekly Release Notes v4.1.0.2

​
Download

​
Distributions

​
Packages

​
Images

​
General Changes

​
Apache Pulsar

(#24752) [fix][client] rollback TopicListWatcher retry behavior (#24698) [fix][client]TopicListWatcher not closed when calling PatternMultiTopicsConsumerImpl.closeAsync() method (#24756) [fix][broker] Fix testServiceConfigurationRetentionPolicy unit test (#24733) [improve][broker] Allow deletion of empty persistent topics regardless of retention policy (#24696) [fix][broker]Fix dirty reading of namespace level offload thresholds (#24683) [fix][broker]Fix the wrong logic of the test PartitionCreationTest.testCreateMissedPartitions (#24634) [fix][broker]Dispatcher did unnecessary sort for recentlyJoinedConsumers and printed noisy error logs (#24749) [fix] Exclude commons-lang dep from bookkeeper (#24743) [fix][client] Fix receiver queue auto-scale without memory limit (#24742) [improve][build] Upgrade Apache Parent POM to version 35 (#24722) [fix][ml] Negative backlog & acked positions does not exist & message lost when concurrently occupying topic owner (#24730) [fix][broker] Ensure KeyShared sticky mode consumer respects assigned ranges (#24736) [fix][broker] Key_Shared subscription doesn’t always deliver messages from the replay queue after a consumer disconnects and leaves a backlog (#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 (#24580) [fix][broker]Fix never recovered metadata store bad version issue if received a large response from ZK

​
KoP

Handle unexpected exception in decode for safe producer state recovery Avoid blocking when the previous consumer closed without sending SyncGroup requests

​
StreamNative Pulsar Plugins

Fix LicenseAdditionalServletTest Use snstage/pulsar image to integration test Removed pinned version for nimbus-jose-jwt-9.37.2 Pin Netty version for bookie_rackinfo Fix BK exclusions to avoid commons-configuration and commons-langs deps Fix sn bom plugin typo

​
pulsarctl

Preserve tenant fields on partial update upgrade client go version to 0.16.0

​
Function Mesh Worker Service

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

​
StreamNative Ursa storage

Use the azure latest image for testing Remove parquet compression property from iceberg table Fix topic properties can not be fetched on the serverless cluster Fix cache reference staleness race condition in ObjectWalStorageImpl Control sdt behavior by the properties Fix offload cursor doesn’t show in the consumer stats Fix unity catalog can’t convert decimal type issue. Fix global open telemetry confict issue Add detailed label for the compaction commit and error metrics Fix record type with instant field write failed issue. Close the writer when there is exceptions Pause the reader when release it Split offload cursor update interval Fix metrics name Add more metrics for the error, commit time 2e957f84 fix ci Introduce exception code to improve the exception handling Support disable the publish task by topic Use latest snapshot version image to fix tests

​
Security Fixes