V3.2.1.4

StreamNative Weekly Release Notes v3.2.1.4

Please note this StreamNative Pulsar distribution will require a valid StreamNative subscription license key to run otherwise the image will fail to start.

Download

Distributions

• https://github.com/streamnative/pulsar/releases/tag/v3.2.1.4

Packages

• Maven Central

Images

• sn-platform

General Changes

Apache Pulsar

[fix][broker] Fix issue of field ‘topic’ is not set when handle GetSchema request

6255b1282e [improve][test][branch-3.2] Improve ManagedLedgerTest.testGetNumberOfEntriesInStorage

9927b55b17 [fix][test][branch-3.2] Fix broken ManagedLedgerTest.testGetNumberOfEntriesInStorage

[improve][misc] Remove the call to sun InetAddressCachePolicy

[fix][broker] Check cursor state before adding it to the waitingCursors

[fix][broker] Avoid expired unclosed ledgers when checking expired messages by ledger closure time

[fix][misc] Make ConcurrentBitSet thread safe

[fix][test] Fix flaky RGUsageMTAggrWaitForAllMsgsTest

[fix][client] Fix wrong results of hasMessageAvailable and readNext after seeking by timestamp

[fix][broker] Avoid execute prepareInitPoliciesCacheAsync if namespace is deleted

[fix][fn] fix broken function-go test

[fix][sec] Go Functions security updates

[fix][test] Fix flaky ManagedLedgerErrorsTest.recoverAfterZnodeVersionError

[fix] [test] Fix flaky test ManagedLedgerTest.testGetNumberOfEntriesInStorage

[fix][client] Consumer lost message ack due to race condition in acknowledge with batch message

[fix][broker] Fix OpReadEntry.skipCondition NPE issue

[fix][ml]Expose ledger timestamp

[improve][misc] Include native epoll library for Netty for arm64

[improve][misc] Upgrade Netty version to 4.1.105.Final

[fix][client]Fixed getting an incorrect maxMessageSize value when accessing multiple clusters in the same process

[improve][admin] Fix the createMissingPartitions doesn’t response correctly

[fix][broker] Fix ResourceGroups loading

[fix][broker] Fix ResourceGroup report local usage

[fix] [broker] fix mismatch between dispatcher.consumerList and dispatcher.consumerSet

[fix] [broker] Close dispatchers stuck due to mismatch between dispatcher.consumerList and dispatcher.consumerSet

KoP

[SNIP-122] Part 3: Support other admin protocols for dot-separated namespace prefix

pulsarctl

Support no auth context

fix token

Add docker hub login

StreamNative Pulsar Plugins

Update license error message for 3.2

Cherry pick license feature to branch 3.2

Function Mesh Worker Service

1f042764 Add brokerAdditionalServlet

allow passing allowed runtimeFlags for java runtime