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

(#22378) (#22961) [feat][broker] PIP-321 Introduce allowed-cluster at the namespace level

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

(#22945) [improve][fn] Make producer cache bounded and expiring in Functions/Connectors

(#22958) [fix][client] Fix orphan consumer when reconnection and closing are concurrency executing

(#22964) [fix][ci] Fix jacoco code coverage report aggregation

(#22962) [improve][misc] Upgrade Bookkeeper to 4.17.1

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

(#22965) [fix][ci] Replace removed macos-11 with macos-latest in GitHub Actions

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

(#22953) [improve] [broker] make system topic distribute evenly.

(#22954) [fix][misc] Rename netty native libraries in pulsar-client-admin-shaded

(#22941) [improve][misc] Set Alpine base image to 3.20 instead of 3.19.1

(#22951) [cleanup][misc] Remove classifier from netty-transport-native-unix-common dependency

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

(#22947) [fix][broker] Check the markDeletePosition and calculate the backlog

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

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

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

(#22924) [fix][test] Fix TableViewBuilderImplTest NPE and infinite loop

(#22910) [fix][fn] Enable optimized Netty direct byte buffer support for Pulsar Function runtimes

(#22879) [fix][misc] Topic name from persistence name should decode local name

(#22890) [fix] [broker] Messages lost on the remote cluster when using topic level replication

KoP

(#607) Log lookup data of all brokers when the topic lookup failed

AWS SQS Connector

(#973) make source queue size configurable

af20c84 fix maunl workflow

d9fb023 feat: Support cutomize trigger a release

pulsarctl

(#1509) Fix json marshal error for Secrets and UserConfigs when creating/updating functions

StreamNative Pulsar Plugins

(#1758) rbac: support primary delegator for fully compatible

(#1719) rbac: support patch/delete the role of role binding

(#1693) rbac: refine document for all the components

StreamNative Tiered storage

(#813) [bugfix] fix lose data when get data from partitioned table

(#814) Iceberg cast utf8 error

(#810) Translate pulsar tenant and namespace to Iceberg namespace

(#807) Support configure offload policy

(#806) remove credentials in print configurations

(#804) Create namespace in rest catalog when namespace not exist

(#803) make iceberg expire snapshot use catalog

(#802) Add topic name in the log message

(#801) Remove credentials in log

(#792) Remove storage path check