StreamNative Weekly Release Notes v4.0.6.6

Download

Distributions

Packages

Images

General Changes

Apache Pulsar

(#24749) [fix] Exclude commons-lang dep from bookkeeper (#24595) [fix][ci] Fix code coverage metrics in Pulsar CI (#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 (#24735) Revert “[fix][broker] Key_Shared subscription doesn’t always deliver messages from the replay queue after a consumer disconnects and leaves a backlog” (#24732) [fix][broker] Key_Shared subscription doesn’t always deliver messages from the replay queue after a consumer disconnects and leaves a backlog (#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

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 beeb69a7c fix image Fix sn bom plugin typo Adapt to the latest topic policies interface from PIP-428

pulsarctl

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

Function Mesh Worker Service

feat: support multiple mcp servers 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

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

Security Fixes