StreamNative Weekly Release Notes v3.3.1.3

Download

Distributions

https://github.com/streamnative/pulsar/releases/tag/v3.3.1.3

Packages

Maven Central

Images

General Changes

Apache Pulsar

[fix] [log] Do not print warn log when concurrently publishing and switching ledgers

[fix][client] the nullValue in msgMetadata should be true by default

[improve] [client]Add new ServiceUrlProvider implementation: SameAuthParamsAutoClusterFailover

[improve][client] Don't print info logs for each schema loaded by client

[improve][broker] Improve pulsar_topic_load_failed metric to record correct failed time

[improve][broker] Optimize high CPU usage when consuming from topics with ongoing txn

[fix] [broker] Topic can never be loaded up due to broker maintains a failed topic creation future

[fix][broker] Skip reading entries from closed cursor.

[improve] [broker] Optimize performance for checking max topics when the topic is a system topic

[improve][broker] Should notify bundle ownership listener onLoad event when ServiceUnitState start (ExtensibleLoadManagerImpl only)

[improve][broker] Support customized shadow managed ledger implementation

[fix][test] Fix flaky SubscriptionSeekTest.testSeekIsByReceive

[feat] Add scripts for updating BK RocksDB ini files

[fix][client] Copy orderingKey to retry letter topic and DLQ messages and fix bug in copying

[fix] DLQ to handle bytes key properly

[fix][broker] Fix shadow topics cannot be consumed when the entry is not cached

AoP

[branch-3.3][fix] Change read max position to earliest position

KoP

Add timeout for metadata recovery operation

StreamNative Pulsar Plugins

Update oidc test token

rbac: migrate snrbac to unified rbac

rbac: fix the async exception chain

Function Mesh Worker Service

f5878bc1 Increase broker memory in ci

Enhance error handling

Filter out empty configs when put kafka connect

fix kafka connect builtin connector use java-opts

support kafka connect builtin worker config

Fix function stats not correct error

Return annotations when get functions/connectors/kafka connects

Read kafka connect config from file

Support pause resume restart for kafka connect