StreamNative Weekly Release Notes v2.10.4.6

Download

Distributions

• https://github.com/streamnative/pulsar/releases/tag/v2.10.4.6

Packages

• Maven Central

Images

• sn-platform

General Changes

Apache Pulsar

5c556334a0 Fix breaking change of the deprecated constructor of PersistentMessageExpiryMonitor

[fix][broker][branch-2.10] Fix NPE when reset Replicator's cursor by position.

(#20597))) Revert "[fix][broker] Fix NPE when reset Replicator's cursor by position.

f8729c0053 [fix][broker] Fix test and checkstyle

c7925b31ec Delete MockManagedCursor.java

a4b3ae5711 Update ConnectionHandlerTest.java

0e70bddbdb Update FaultInjectableZKRegistrationManager.java

7670e01d14 Update MetadataStoreTest.java - The prior PR was not checked against codestyle

[fix] [client] Messages lost when consumer reconnect

[fix][client] Make the whole grabCnx() progress atomic

[fix][meta] Bookie Info lost by notification race condition.

9a6a460563 [fix][test] Fix the test introduced in #18804

[fix][broker] Fix namespace deletion if __change_events topic has not been created yet

[fix][schema] Only handle exception when there has

[fix][broker] Topic policy can not be work well if replay policy message has any exception.

7b6d1c9116 [fix][test] Fix the compilation issue introduced in #20597

[fix][broker] Fix NPE when reset Replicator's cursor by position.

e6d4f09c44 [fix][test] Fix test testThreadSwitchOfZkMetadataStore

[fix][test] Replace test call to Auth0 with call to WireMock

[fix][broker] Fix return the earliest position when query position by timestamp.

[fix][offload] Filesystem offloader class not found hadoop-hdfs-client

[improve][admin] Return BAD_REQUEST on cluster data is null for createCluster

[fix] [meta]Switch to the metadata store thread after zk operation

[fix][test] Fix flaky testCreateTopicWithZombieReplicatorCursor

[fix][client] Fix race condition that leads to caching failed CompletableFutures in ConnectionPool

[fix][fn] Make KubernetesRuntime translate characters in function tenant, namespace, and name during function removal to avoid label errors

[fix][broker] Return if AbstractDispatcherSingleActiveConsumer closed

[fix][fn] Fix JavaInstanceStarter inferring type class name error

[fix] [txn] fix consumer can receive aborted txn message when readType is replay

[broker] clean inactive bundle from bundleData in loadData and bundlesCache

[fix][ws] Remove unnecessary ping/pong implementation

[fix][flaky-test]NamespaceServiceTest.flaky/testModularLoadManagerRemoveBundleAndLoad

fix: bundle-data metadata leak because of bundlestats was not clean

KoP

[branch-2.10.4][improve] Pass group ID to authorizer when using OAuth

[improvement] Remove expensive useless String.format() in canConsumeAsync

Cloud Pulsar Plugins

[improve] Add cache for parse claims Jwt

Fix authenticate http request

[improve] Move authz parse jwt body logic to authenticaiton state init stage

Aws EventBridge Connector

c3367b7 Fix v2.10.4.x will fix sink name.

Improve prerequisites docs.