StreamNative Weekly Release Notes v4.0.6.2

General Changes

Apache Pulsar

(#24602) [improve][broker]Part-2 Add Admin API to delete topic policies (#24390) [improve][admin] PIP-422 part 1: Support global topic-level replicated clusters policy (#24642) [fix][ws] Allow websocket principals to specify originalPrincipal without proxy role (#24633) [fix][test]fix flaky ZeroQueueSizeTest.testZeroQueueGetExceptionWhenReceiveBatchMessage (#24632) [fix][test] Fix ConcurrentModificationException in Ipv4Proxy (#24617))) Revert “[improve][broker] Upgrade avro version to 1.12.0 (#24604) [improve][io] Add dependency file name information to error message when .nar file validation fails with ZipException (#24617) [improve][broker] Upgrade avro version to 1.12.0 (#24606) [improve][broker]Remove block calling that named cursor.asyncGetNth when expiring messages (#24607) [improve][broker]Improve the anti-concurrency mechanism expirationCheckInProgress (#24615) [fix][ws] Fix WebSocket authentication with authenticateOriginalAuthData enabled (#24613) [fix][ws] Fix WebSocket proxy originalPrincipal for HTTP admin API calls (#24630) [fix][test]fix flaky ZeroQueueSizeTest.testZeroQueueGetExceptionWhenReceiveBatchMessage (#24626) [fix][proxy] Fix TooLongFrameException with Pulsar Proxy (#24621) [fix][broker] Fix duplicate watcher registration after SessionReestablished (#24610) [fix][client]Prevent ZeroQueueConsumer from receiving batch messages when using MessagePayloadProcessor

KoP

Fix Kafka Connect’s topic replay loop might be stuck when all messages have been compacted out Fix possible deadlock of system topic access due to blocking call when holding the lock Fix incorrect ListOffsets result on a compacted topic 442d6967f [branch-3.0] Bump version to 4.0.6.2 Add partition name to error logs in PartitionLog and UrsaPartitionLog classes Fix retention.ms may overflow when converting to the Pulsar retention policy

Function Mesh Worker Service

Create a new sub module mesh-worker-common 67fe201a Cleanup disk

StreamNative Tiered storage

Introduce flag to control delta add file stats Delta schema evolution support delete field Unity catalog support update table schema.

StreamNative Unified RBAC

fix(acl): avoid parsing token from data source

StreamNative Ursa storage

43600e8f revert b3f2c62 (#1192))) Revert “Adapt new changes for TopicCompactionService interface Adapt new changes for TopicCompactionService interface USe Hessian2 as the new task serialization. Fix delete package task bug Fix topic medata not found issue. Fix: Use shared static thread pool for PulsarLakehouseReader idle timeout Upgrade iceberg to 1.9.2 Unblock the compact process when encounter task deserialize exception (#1192))) Revert “Adapt new changes for TopicCompactionService interface Adapt new changes for TopicCompactionService interface