StreamNative Weekly Release Notes v3.3.1.5

Download

Distributions

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

Packages

Maven Central

Images

General Changes

Apache Pulsar

[fix][broker] Fix retry backoff for PersistentDispatcherMultipleConsumers

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

[fix] Bump io.grpc from 1.56.0 to 1.56.1

[fix][broker] fix pulsar-admin topics stats-internal caused a BK client thread a deadlock

[improve][broker] Optimize message payload traffic for ShadowReplicator

[fix][broker] Execute the pending callbacks in order before ready for incoming requests

[fix][test] Fix flaky UnloadSubscriptionTest.testMultiConsumer

[improve][admin] PIP-369 Introduce unload flag in ns-isolation-policy set call

[improve][misc] Upgrade Netty to 4.1.113 and netty-tcnative to 2.0.66

[improve][broker] Add retry for start service unit state channel (ExtensibleLoadManagerImpl only)

[fix][broker] Fix brokers still retry start replication after closed the topic

[improve][broker] Reschedule reads with increasing backoff when no messages are dispatched

MoP

Support mTLS authentication for MoP

Fix workflow

Implement AuthenticationProviderMTls

KoP

Redesign the metrics related to Fetch requests

pulsarctl

Setup go version to 1.22 fix cve

StreamNative Pulsar Plugins

7e5f3dac delete rbac CI since it has been moved to unified-rbac repo

Add authType field for IdentityPool

Cloud Pulsar Plugins

fix kafka connect skip api regex

Function Mesh Worker Service

Update oxia to latest and always pull image

Support alter/reset kafka connect offsets

Use defaultNamespace to check kafka connect permission

Google BigQuery Sink Connector

Support batch max bytes limit to 10Mb