StreamNative Weekly Release Notes v3.3.0.4

Download

Distributions

https://github.com/streamnative/pulsar/releases/tag/v3.3.0.4

Packages

Maven Central

Images

General Changes

Apache Pulsar

[feat][broker] PIP-321 Introduce allowed-cluster at the namespace level

[fix][broker] Fix updatePartitionedTopic when replication at ns level and topic policy is set

[improve][fn] Make producer cache bounded and expiring in Functions/Connectors

[fix][client] Fix orphan consumer when reconnection and closing are concurrency executing

[fix][ci] Fix jacoco code coverage report aggregation

[improve][misc] Upgrade Bookkeeper to 4.17.1

[improve][misc] Replace rename-netty-native-libs.sh script with renaming with maven-shade-plugin

[fix][ci] Replace removed macos-11 with macos-latest in GitHub Actions

(#22908))) Revert "[improve][broker] Optimize ConcurrentOpenLongPairRangeSet by RoaringBitmap

[improve] [broker] make system topic distribute evenly.

[fix][misc] Rename netty native libraries in pulsar-client-admin-shaded

[improve][misc] Set Alpine base image to 3.20 instead of 3.19.1

[cleanup][misc] Remove classifier from netty-transport-native-unix-common dependency

[improve][broker] Optimize ConcurrentOpenLongPairRangeSet by RoaringBitmap

[fix][broker] Check the markDeletePosition and calculate the backlog

[fix][fn] Support compression type and crypto config for all producers in Functions and Connectors

[fix] [broker] broker log a full thread dump when a deadlock is detected in healthcheck every time

[fix] [client] Fix resource leak in Pulsar Client since HttpLookupService doesn't get closed

[fix][test] Fix TableViewBuilderImplTest NPE and infinite loop

[fix][fn] Enable optimized Netty direct byte buffer support for Pulsar Function runtimes

[fix][misc] Topic name from persistence name should decode local name

[fix] [broker] Messages lost on the remote cluster when using topic level replication

KoP

Log lookup data of all brokers when the topic lookup failed

AWS SQS Connector

make source queue size configurable

af20c84 fix maunl workflow

d9fb023 feat: Support cutomize trigger a release

pulsarctl

Fix json marshal error for Secrets and UserConfigs when creating/updating functions

StreamNative Pulsar Plugins

rbac: support primary delegator for fully compatible

rbac: support patch/delete the role of role binding

rbac: refine document for all the components

StreamNative Tiered storage

[bugfix] fix lose data when get data from partitioned table

Iceberg cast utf8 error

Translate pulsar tenant and namespace to Iceberg namespace

Support configure offload policy

remove credentials in print configurations

Create namespace in rest catalog when namespace not exist

make iceberg expire snapshot use catalog

Add topic name in the log message

Remove credentials in log

Remove storage path check