StreamNative Weekly Release Notes v3.0.4.4

Download

Distributions

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

Packages

Maven Central

Images

General Changes

Apache Pulsar

[fix][broker] Reader stuck after call hasMessageAvailable when enable replicateSubscriptionState

[fix][test] Flaky-test: ManagedLedgerTest.testTimestampOnWorkingLedger

[improve][broker] Propagate cause exception in TopicBusyException when applicable

[improve][meta] Log a warning when ZK batch fails with connectionloss

[fix][test] Clear fields in test cleanup to reduce memory consumption

[fix][test] Fix resource leak in TransactionCoordinatorClientTest

[fix][admin] Fix namespace admin api exception response

[improve][sec] Align some namespace level policy authorisation check

[fix][broker] Fix BufferOverflowException and EOFException bugs in /metrics gzip compression

[fix][io] CompressionEnabled didn't work on elasticsearch sink

6e849fcb06 [fix][test][branch-3.0] Fix test PersistentTopicsTest.testUpdatePartitionedTopic

d6791a8de2 Revert "[fix][test][branch-3.0] Fix broken ManagedLedgerTest.testGetNumberOfEntriesInStorage"

[fix][offload] Increase file upload limit from 2048MiB to 4096MiB for GCP/GCS offloading

[fix][broker] upgrade jclouds 2.5.0 -> 2.6.0

[fix][ml] Fix NPE of getValidPositionAfterSkippedEntries when recovering a terminated managed ledger

[improve][broker] Support X-Forwarded-For and HA Proxy Protocol for resolving original client IP of http/https requests

[fix][broker] Fix broken topic policy implementation compatibility with old pulsar version

[fix][broker] Fix typos in Consumer class

[improve][test] Move ShadowManagedLedgerImplTest to flaky tests

[improve][broker] Repeat the handleMetadataChanges callback when configurationMetadataStore equals localMetadataStore

[improve][broker] Add topic name to emitted error messages.

[improve] Make the config metricsBufferResponse description more effective

[fix][test] SchemaMap in AutoConsumeSchema has been reused

[improve][broker] backlog quota exceed limit log replaced with debug

[fix][broker] Fix message drop record in producer stat

[fix][broker] Update topic partition failed when config maxNumPartitionsPerPartitionedTopic<0

[improve][build] Upgrade Lombok to 1.18.32 for Java 22 support

AoP

[fix] Fix AoP can't work when enabling Pulsar transaction

KoP

[Bug fix] Fix the geo-replication message drop caused by the message metadata's producer name not being set

AMQP1_0 Connector

Fix integration test due to invalid package storage path

StreamNative Pulsar Plugins

auditlog: perf: create AuditLogEvent instances only when there's a matching rule

Deferred generation id for AuditLogEvent

auditlog: replace rw lock & HashMaps with ConcurrentHashMap to reduce blocking code

auditlog: optimize uri matching by organizing condition and eliminating streams

auditlog: Cache regex compilation

Google BigQuery Sink Connector

upgrade depend to fix cve

Aws EventBridge Connector

Bump org.apache.avro:avro from 1.10.2 to 1.11.3