Skip to main content

StreamNative Weekly Release Notes v3.0.5.5

Download

Distributions

Packages

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
I