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

(#22572) [fix][broker] Reader stuck after call hasMessageAvailable when enable replicateSubscriptionState

(#22600) [fix][test] Flaky-test: ManagedLedgerTest.testTimestampOnWorkingLedger

(#22596) [improve][broker] Propagate cause exception in TopicBusyException when applicable

(#22566) [improve][meta] Log a warning when ZK batch fails with connectionloss

(#22583) [fix][test] Clear fields in test cleanup to reduce memory consumption

(#21380) [fix][test] Fix resource leak in TransactionCoordinatorClientTest

(#22587) [fix][admin] Fix namespace admin api exception response

(#21640) [improve][sec] Align some namespace level policy authorisation check

(#22576) [fix][broker] Fix BufferOverflowException and EOFException bugs in /metrics gzip compression

(#22565) [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"

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

(#22220) [fix][broker] upgrade jclouds 2.5.0 -> 2.6.0

(#22552) [fix][ml] Fix NPE of getValidPositionAfterSkippedEntries when recovering a terminated managed ledger

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

(#22535) [fix][broker] Fix broken topic policy implementation compatibility with old pulsar version

(#22532) [fix][broker] Fix typos in Consumer class

(#22526) [improve][test] Move ShadowManagedLedgerImplTest to flaky tests

(#22519) [improve][broker] Repeat the handleMetadataChanges callback when configurationMetadataStore equals localMetadataStore

(#22506) [improve][broker] Add topic name to emitted error messages.

(#22490) [improve] Make the config metricsBufferResponse description more effective

(#22500) [fix][test] SchemaMap in AutoConsumeSchema has been reused

(#22488) [improve][broker] backlog quota exceed limit log replaced with debug

(#22458) [fix][broker] Fix message drop record in producer stat

(#22397) [fix][broker] Update topic partition failed when config maxNumPartitionsPerPartitionedTopic<0

(#22425) [improve][build] Upgrade Lombok to 1.18.32 for Java 22 support

AoP

(#1070) [fix] Fix AoP can't work when enabling Pulsar transaction

KoP

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

AMQP1_0 Connector

(#898) Fix integration test due to invalid package storage path

StreamNative Pulsar Plugins

(#1659) auditlog: perf: create AuditLogEvent instances only when there's a matching rule

(#1658) Deferred generation id for AuditLogEvent

(#1655) auditlog: replace rw lock & HashMaps with ConcurrentHashMap to reduce blocking code

(#1654) auditlog: optimize uri matching by organizing condition and eliminating streams

(#1653) auditlog: Cache regex compilation

Google BigQuery Sink Connector

(#555) upgrade depend to fix cve

Aws EventBridge Connector

(#187) Bump org.apache.avro:avro from 1.10.2 to 1.11.3