StreamNative Weekly Release Notes v4.0.0.7

Download

Distributions

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

Packages

Maven Central

Images

General Changes

Apache Pulsar

[improve] Upgrade oxia-java to 0.4.10 and fix closing of OxiaMetadataStore

[fix][client] Fix deadlock of NegativeAcksTracker

[improve][broker] Decouple pulsar_storage_backlog_age_seconds metric with backlogQuota check

[fix][client] Make protobuf-java dependency optional in java client libraries

[improve] Use single buffer for metrics when noUnsafe use

[fix][broker] fix null lookup result when brokers are starting

[fix][client] Fixed an issue where a cert chain could not be used in TLS authentication

[improve][misc] Disable OTel by default when running the pulsar-perf tool

[cleanup][build] skip generating pom.xml.versionsBackup

[fix][client] Initializing client-authentication using configured auth params

[fix][ws] Implement missing http header data functions in AuthenticationDataSubscription

[fix][misc] Class conflict during jetcd-core-shaded shading process

[improve][test] Reduce OneWayReplicatorUsingGlobalZKTest.testRemoveCluster execution time

[improve][broker] Skip unloading when bundle throughput is zero (ExtensibleLoadManagerImpl only)

[improve][broker] Reduce memory occupation of the delayed message queue

[fix][client] fix incomingMessageSize and client memory usage is negative

[fix][fn] ack messages for window function when its result is null

[improve] Improve logic for enabling Netty leak detection

[improve][ml] Avoid repetitive nested lock for isMessageDeleted in ManagedCursorImpl

KoP

[Ursa] Don't fail with OFFSET_OUT_OF_RANGE when LEO is less than the fetch offset

AWS Lambda Connector

Support include publish time to metadata

StreamNative Pulsar Plugins

Change authentication failed log level to warn

Upgrade aws sdk dependency version to v2

exlude netty for aws-jdk

Cloud Pulsar Plugins

Allow accepting token from query parameters

Function Mesh Worker Service

Set processingGuarantee for window functions

Bump function-mesh to v0.23.0

StreamNative Ursa storage

Fix the commit runner race condition issue.

Update streamId if Shadow Managed Ledger stream ID is invalid

Trigger the metadata update when calling getLastConfirmed entry

[improve][tests] covered Pulsar protocol retention and backlog quota

[improve][tests] covers Pulsar protocol encryption and compression tests

Remove awssdk bundle dependency

Avoiding the risk of pending add buffer release

fix netty and json cve

Fix the stream id is duplicated

Do not reject the entries bigger than write buffer

Support the azure file storage

[improve][tests] enabled ExtensibleLoadBalancer in integ tests and added delayed messaging test

[improve][tests] enabled concurrent tests in integ and enabled new load balancer