StreamNative Weekly Release Notes v3.0.0.4

Download

Distributions

• https://github.com/streamnative/pulsar/releases/tag/v3.0.0.4

Packages

• Maven Central

Images

• sn-platform

General Changes

Apache Pulsar

(#20597))) Revert "[fix][broker] Fix NPE when reset Replicator's cursor by position.

[fix][broker] Revert "Skip loading broker interceptor when disableBrokerInterceptors is true #20422"

[improve][broker] Make ExtensibleLoadManagerImpl's broker filter pure async

[fix][test] Fix flaky test ExtensibleLoadManagerTest.testIsolationPolicy

[improve][test] Add integration test for ExtensibleLoadManager

[fix][broker] Added the skipped message handler for ServiceUnitStateChannel

[fix][client] Make the whole grabCnx() progress atomic

[improve][broker] Make get list from bundle Admin API async

[fix][sql] Remove useless configuration for Pulsar SQL

[fix][io] Close the kafka source connector got stuck

[fix][txn] Use PulsarResource check for topic existence instead of brokerservice.getTopic()

[fix][offload] Filesystem offloader class not found hadoop-hdfs-client

[fix] [Perf] PerformanceProducer do not produce expected number of messages.

[fix][broker] Fix return the earliest position when query position by timestamp.

[fix][broker] Topic policy can not be work well if replay policy message has any exception.

[fix][broker] Fix NPE when reset Replicator's cursor by position.

[fix][meta] Bookie Info lost by notification race condition.

[fix][meta] Adding the missed bookie id in the registration manager.

[improve][broker] Upgrade bookkeeper to 4.16.2

[fix][broker]fix the publish latency spike issue with large number of producers

[fix][fn] Exit JVM when main thread throws exception

[fix][client]Fix deadlock issue of consumer while using multiple IO threads

[fix][broker] Fix the publish latency spike from the contention of MessageDeduplication

[fix] [admin] set ns level backlog quota does not take effect if retention exists

[improve][test] Disable disk usage threshold & geoip download and enable logging for Elastic Testcontainers

[improve][bk] Add integration test with bookie http server enabled

[improve][broker] Support cgroup v2 by using jdk.internal.platform.Metrics in Pulsar Loadbalancer

AoP

[ci] Ignore the jms1_1 test first

KoP

[transaction] Implement producer state manager recovery

Fix flaky OffsetTopicWriteTimeoutTest

[transactions] Better handling of network exceptions while sending TX markers

[transaction] Producer state manager snapshot recovery - Part-1: Add snapshot I/O buffer

Reduce the offset commit timeout to 5 seconds and make it configurable

Fix flaky CompactedPartitionedTopicTest.testClose

[improvements] Use the TopicEventListener API

[improvement] Remove expensive useless String.format() in canConsumeAsync

StreamNative Pulsar Plugins

[fix][test] Reinstall the component ca-certificates-java in the DockerFile of detector test

Function Mesh Worker Service

Support manual semantics