StreamNative Weekly Release Notes v3.0.5.5

Download

Distributions

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

Packages

Maven Central

Images

General Changes

Apache Pulsar

[fix][broker] Can't connecte to non-persist topic when enable broker client tls

[fix][broker] Fix broker OOM when upload a large package.

[improve][broker] Improve exception for topic does not have schema to check

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

[improve] [broker] PIP-356 Support Geo-Replication starts at earliest position

[fix][broker] Support lookup options for extensible load manager

[fix][broker] Check the broker is available for the SLA monitor bundle when the ExtensibleLoadManager is enabled

[fix][broker] Ensure that PulsarService is ready for serving incoming requests

[fix][broker] Update init and shutdown time and other minor logic (ExtensibleLoadManagerImpl only)

[fix][broker] Asynchronously return brokerRegistry.lookupAsync when checking if broker is active(ExtensibleLoadManagerImpl only)

[fix][broker] Fix NPE after publishing a tombstone to the service unit channel

[fix][broker] Immediately tombstone Deleted and Free state bundles

[fix][broker] Fix Replicated Topic unload bug when ExtensibleLoadManager is enabled

[improve][broker]Ensure namespace deletion doesn't fail

[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] 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][misc][branch-3.2] Upgrade to Bookkeeper 4.16.6

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

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

[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

[improve] Refactored BK ClientFactory to return futures

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

[fix][test] Fix thread leaks in Managed Ledger tests and remove duplicate shutdown code

[fix][client] fix producer/consumer perform lookup for migrated topic

[fix] [broker] response not-found error if topic does not exist when calling getPartitionedTopicMetadata

[improve] [client] PIP-344 support feature flag supportsGetPartitionedMetadataWithoutAutoCreation

[fix] [client] PIP-344 Do not create partitioned metadata when calling pulsarClient.getPartitionsForTopic(topicName)

AoP

[branch-3.0] Bump Pulsar 3.0.5.5

MoP

cf6e090 Upgrade version to 3.0.5.5

KoP

Fix the TopicExistsInfo object not recycled

Cloud Storage Connector

[fix]: fix Parquet/Avro format with separated key value avro-avro messages

AWS SQS Connector

Support load config from secrets

make source queue size configurable

77e3b1b fix maunl workflow

75ba9d4 feat: Support cutomize trigger a release

pulsarctl

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

StreamNative Pulsar Plugins

[branch-3.0] Bump Pulsar 3.0.5.5

c619b912 Fix pulsar-broker-auth-multiple-key-token version

Support multiple private keys token AuthenticationProvider

Cloud Pulsar Plugins

[branch-3.0] Compatible changes for Auth0 Actions migration

[branch-3.0] Bump Pulsar 3.0.5.5

Function Mesh Worker Service

bump sn-operator to v0.5.0-rc.15

add kafka connect apis

Bump function mesh to 0.21.0

Snowflake Connector

Improve json schema conversion