Skip to main content

​
StreamNative Weekly Release Notes v3.0.4.4

​
Download

​
Distributions

​
Packages

​
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
⌘I