StreamNative Weekly Release Notes v3.3.2.1

Download

Distributions

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

Packages

Maven Central

Images

General Changes

Apache Pulsar

[fix][broker] Fix namespace unload might be blocked too long with extensible load manager

[fix] [broker] Topics failed to delete after remove cluster from replicated clusters set and caused OOM

[fix][broker] timeout when broker registry hangs and monitor broker registry (ExtensibleLoadManagerImpl only)

[fix][broker] Fix the broker registering might be blocked for long time

[fix][client] Fix producer/consumer stop to reconnect or Pub/Sub due to IO thread race-condition

[fix][test] Fix running ClusterMetadataSetupTest in IDE

[fix][broker] Fix unloadNamespaceBundlesGracefully can be stuck with extensible load manager

[fix][client] Use dedicated executor for requests in BinaryProtoLookupService

[fix] [proxy] Fix pattern consumer does not work when using Proxy

[fix][test] Fix memory leak via OTel shutdown hooks in tests

[improve][test] Added message properties tests for batch and non-batch messages

[fix][client] Prevent embedding protobuf-java class files in pulsar-client-admin and pulsar-client-all

[improve][io] Upgrade Spring version to 6.1.13 in IO Connectors

[improve][broker] Add log to track issue when handleGetTopicsOfNamespace

[fix][test] Address flaky GetPartitionMetadataMultiBrokerTest

[fix][client] Fix the javadoc for ConsumerBuilder.isAckReceiptEnabled

[fix][build] Add basic support for vscode-java and Eclipse IDE

[fix][test] Fix flaky test ManagedLedgerTest.testDeleteCurrentLedgerWhenItIsClosed

[fix][test] Fix flaky GetPartitionMetadataMultiBrokerTest.testCompatibilityDifferentBrokersForNonPersistentTopic

[improve][broker] Make cluster metadata init command support metadata config path

AoP

Fix the publish latency unit

KoP

Re-implement the EventManager

Google BigQuery Sink Connector

Remove unnecessary version define

Add table type validation logic

Add google partner header

Upgrade google lib version

[feat] Support sync properties to biguqery