StreamNative Weekly Release Notes v2.11.1.2

Download

Distributions

https://github.com/streamnative/pulsar/releases/tag/v2.11.1.2

Packages

Maven Central

Images

General Changes

Apache Pulsar

6fe835ec4b Fix compile issue

(#20141) [fix][broker] Fix entry filter feature for the non-persistent topic

(#20381) [improve][monitor] Add JVM start time metric

(#20346) [improve][admin] Return BAD_REQUEST on cluster data is null for createCluster

(#20335) [fix] [broker] In Key_Shared mode: remove unnecessary mechanisms of message skip to avoid unnecessary consumption stuck

(#18315) [fix][broker] fix consume stuck of shared streaming dispatcher

(#20316) [improve][cli] Allow pulser-client consume create a replicated subscription

(#20310) [fix][broker] Fix class name typo PrecisPublishLimiter to "Precise"

(#20189) [fix][broker]Fix deadlock of metadata store

(#20115) [improve][fn] Use functions classloader in TopicSchema.newSchemaInstance() to fix ClassNotFoundException when using custom SerDe classes. (targeted for master)

(#20343) [fix][test] Use delta when comparing doubles in checkLoadReportNicSpeed

(#20276) [fix][ml] Fix ledger left in OPEN state when enable inactiveLedgerRollOverTimeMs

(#20250) [fix][broker] Fix default bundle size used while setting bookie affinity

KoP

(#1854) Fix list offsets for times failure when ledgers are removed by a rollover operation

(#1853) Fix flaky-test: KafkaNonPartitionedTopicTest.testNonPartitionedTopic

(#1848) Use brokerClientTlsEnabled to configure pulsar client

(#1835) [fix][schema] Fix the schema registry tests and enabled the schema tests in CI

StreamNative Pulsar Plugins

21e18bd5 Fix compile issue

Upgrade go version

Support publish json content type message

Unify the dependencies version between Pulsar and plugins

Function Mesh Worker Service

fix yq

fix e2e pulsar install

Reuse existing configs

Show windowConfig when get function

Cleanup functions/sinks/sources after delete