> ## Documentation Index
> Fetch the complete documentation index at: https://docs.streamnative.io/llms.txt
> Use this file to discover all available pages before exploring further.

# StreamNative Weekly Release Notes v3.0.0.4

# StreamNative Weekly Release Notes v3.0.0.4

## Download

### Distributions

* [https://github.com/streamnative/pulsar/releases/tag/v3.0.0.4](https://github.com/streamnative/pulsar/releases/tag/v3.0.0.4)

### Packages

* [Maven Central](https://search.maven.org/artifact/io.streamnative/pulsar/3.0.0.4/pom)

### Images

* [sn-platform](https://hub.docker.com/layers/streamnative/sn-platform/3.0.0.4/images/sha256-c2de684b34ef0f5e81449ed1aaa643e6d96c92098dd6dadeedbe7d38259575ae)

## General Changes

### Apache Pulsar

([#20597)](https://github.com/apache/pulsar/pull/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