StreamNative Weekly Release Notes v3.0.1.7

Download

Distributions

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

Packages

• Maven Central

Images

• sn-platform

General Changes

Apache Pulsar

[fix][broker] Fix resource_quota_zpath

[fix][broker] Fix setReplicatedSubscriptionStatus incorrect behavior

[improve] [broker] Let the producer request success at the first time if the previous one is inactive

[fix][broker] Correct schema deletion for parititioned topic

[fix] [broker] Delete topic timeout due to NPE

[fix][broker] Fix issue with consumer read uncommitted messages from compacted topic

[fix][broker] Duplicate LedgerOffloader creation when namespace/topic…

dc198df524 Revert "Release 3.0.2"

[fix][broker] Fix create topic with different auto creation strategies causes race condition

[fix][broker] Fix namespace bundle stuck in unloading status

[fix] [build] Remove test testNoOrphanTopicIfInitFailed

(#21270))) Revert "[fix][client] Avert extensive time consumption during table view construction

[fix][client] Fix print error log 'Auto getting partitions failed' when expend partition.

[fix] [broker] Fix thousands orphan PersistentTopic caused OOM

[fix] [ml] Fix orphan scheduled task for ledger create timeout check

[fix][broker] Fix failure while creating non-durable cursor with inactive managed-ledger

[fix][ml] Fix unfinished callback when deleting managed ledger

[fix][client] Avert extensive time consumption during table view construction

[fix][broker] Fix the deadlock when using BookieRackAffinityMapping with rackaware policy

[fix][broker] Fix PulsarService/BrokerService shutdown when brokerShutdownTimeoutMs=0

[fix][txn] OpRequestSend reuse problem cause tbClient commitTxnOnTopic timeout unexpectedly

[fix][broker] Avoid pass null role in MultiRolesTokenAuthorizationProvider

[fix][txn] Ack all message ids when ack chunk messages with transaction.

[fix][build] Fix apt download issue in building the docker image

[fix] [broker] Make the new exclusive consumer instead the inactive one faster

KoP

Fix NPE for OffsetsFetch v7 or earlier requests

Apply restrict checkstyle rules for indents and spaces

[Branch-3.0][transaction] Make the list offset request aware of the read-committed isolation level

[schema-registry][fix] Fix schema ID generation logic

[fix] Use log end offset as the earliest offset when topic is empty

Cloud Storage Connector

Optimize Azure blob storage connector config validation logic

Add azure blob storage sink connector docs.

Add Google Cloud Storage sink connector docs.

Add AWS s3 sink connector docs.

AWS Lambda Connector

Make AWS Lambda sink connector private

StreamNative Pulsar Plugins

Fix cve

Function Mesh Worker Service

Fallback to reason field if the lastState's message is empty

make memory padding configurable

Fix getSinkList and getSourceList impl to avoid showing fields details.

67e808c0 Use local registry for sn-java and generic runner images

Support read customize connector catalogs.

Support generic runtime

Append version to the description field of ConnectorDefinition for load from connector catalog

Lakehouse Connector

Update snappy dependency

Snowflake Connector

Improve snowflake sink connector doc

Fix wrong value for configuration processingGuarantees

Aws EventBridge Connector

Fix some docs and deprecated eventBusResourceName config.