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

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

(#22989) [fix][broker] Fix broker OOM when upload a large package.

(#22974) [improve][broker] Improve exception for topic does not have schema to check

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

(#22856) [improve] [broker] PIP-356 Support Geo-Replication starts at earliest position

(#22487) [fix][broker] Support lookup options for extensible load manager

(#22485) [fix][broker] Check the broker is available for the SLA monitor bundle when the ExtensibleLoadManager is enabled

(#22977) [fix][broker] Ensure that PulsarService is ready for serving incoming requests

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

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

(#22859) [fix][broker] Fix NPE after publishing a tombstone to the service unit channel

(#22743) [fix][broker] Immediately tombstone Deleted and Free state bundles

(#22496) [fix][broker] Fix Replicated Topic unload bug when ExtensibleLoadManager is enabled

(#22627) [improve][broker]Ensure namespace deletion doesn't fail

(#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

(#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

(#22963) [improve][misc][branch-3.2] Upgrade to Bookkeeper 4.16.6

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

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

(#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

(#22853) [improve] Refactored BK ClientFactory to return futures

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

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

(#21356) [fix][client] fix producer/consumer perform lookup for migrated topic

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

(#22773) [improve] [client] PIP-344 support feature flag supportsGetPartitionedMetadataWithoutAutoCreation

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

AoP

(#1279) [branch-3.0] Bump Pulsar 3.0.5.5

MoP

cf6e090 Upgrade version to 3.0.5.5

KoP

(#618) Fix the TopicExistsInfo object not recycled

Cloud Storage Connector

(#974) [fix]: fix Parquet/Avro format with separated key value avro-avro messages

AWS SQS Connector

(#713) Support load config from secrets

(#973) make source queue size configurable

77e3b1b fix maunl workflow

75ba9d4 feat: Support cutomize trigger a release

pulsarctl

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

StreamNative Pulsar Plugins

(#1766) [branch-3.0] Bump Pulsar 3.0.5.5

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

(#1682) Support multiple private keys token AuthenticationProvider

Cloud Pulsar Plugins

(#1102) [branch-3.0] Compatible changes for Auth0 Actions migration

(#1092) [branch-3.0] Bump Pulsar 3.0.5.5

Function Mesh Worker Service

(#1372) bump sn-operator to v0.5.0-rc.15

(#1359) add kafka connect apis

(#1337) Bump function mesh to 0.21.0

Snowflake Connector

(#436) Improve json schema conversion