StreamNative Weekly Release Notes v4.0.0.2

Download

Distributions

https://github.com/streamnative/pulsar/releases/tag/v4.0.0.2

Packages

Maven Central

Images

General Changes

Apache Pulsar

[feat][meta] Bump oxia java version from 0.4.5 to 0.4.7

[fix][client] Fix producer/consumer stop to reconnect or Pub/Sub due to IO thread race-condition

[fix][broker] Key_Shared subscription: Reject consumers with incompatible policy

[fix][test] Fix running ClusterMetadataSetupTest in IDE

[fix] [proxy] Fix pattern consumer does not work when using Proxy

[fix][test] Prevent OOM in test by not spying invocations in SimpleProducerConsumerTest

[improve][monitor] Upgrade OTel to 1.41.0

[feat][monitor] Add offloader stats grafana dashboard

[fix][client] Prevent embedding protobuf-java class files in pulsar-client-admin and pulsar-client-all

[fix][client] Fix ConsumerStats.getRateMsgsReceived javadoc

[fix][client] Use dedicated executor for requests in BinaryProtoLookupService

8c20e64651 Bump version to 4.0.1-SNAPSHOT

KoP

Remove all coordinator epoch usages

Cloud Storage Connector

feat: Support new batch model BLEND/PARTITIONED

Google BigQuery Sink Connector

Upgrade google lib version

[feat] Support sync properties to biguqery

StreamNative Ursa storage

Fix the flaky test testOperationRejection

Fix wrong metadata updates for first and last entry headers

Increase commit runner concurrency

Fix som cve

feat(distributed-lock): use metadata oxia client as distributed lock client

Use concurrent map for the cache strings in storageApi

[cleanup] Move the metrics part out of the implementation

Make the maxPendingAddRequest dynamic

Correct the dockerfile used file location

Make the sync method call the async method to get result

Fix the request rejection of SimpleStorageImpl

Fix the missed exception handling for getting the next read index

Fix prepared publish task may failed issue.

Fix the ledger deletion for PersistCache