V4.0.1.2
StreamNative Weekly Release Notes v4.0.1.2
Download
Distributions
Packages
Images
General Changes
Apache Pulsar
(#23871) [feat][misc] upgrade oxia java client to 0.5.0
(#23864) [improve][broker] Improve Consumer.equals performance
(#23863) [improve] Upgrade to Netty 4.1.117.Final
(#23862) [improve][broker] Remove spamming logs for customized managed ledger
(#23857) [fix][test] Add reconsumeLater call in RetryTopicTest#testRetryTopicWithMultiTopic.
(#23853) [fix][client] Orphan producer when concurrently calling producer closing and reconnection
(#23384))) (#23855) [fix][broker] Revert “[fix][broker] Cancel possible pending replay read in cancelPendingRead
(#23854) [fix][broker] Fix deadlock in Key_Shared PIP-379 implementation
(#23851) [improve][ci] Publish build scans to develocity.apache.org
(#23852) [fix][test]Fix flaky test testTopicUnloadAfterSessionRebuild
(#23846) [improve] Support overriding java.net.preferIPv4Stack with OPTS
(#23712) [fix][broker] PIP-399: Fix Metric Name for Delayed Queue
(#23833) [fix][broker] Fix possible mark delete NPE when batch index ack is enabled
(#23841) [fix] [broker] Fix acknowledgeCumulativeAsync block when ackReceipt is enabled
(#23847) [fix][misc] Honor dynamic log levels in log4j2.yaml
(#23832) [fix][broker] Remove blocking calls from internalGetPartitionedStats
(#23842) [fix][broker] Continue using the next provider for http authentication if one fails
(#23839) [improve][broker] Reduce unnecessary REPLICATED_SUBSCRIPTION_SNAPSHOT_REQUEST
AoP
(#1519) Fix SN bom version
(#1501) Fix build script
MoP
(#1609) Fix build script
(#1606) Use SN bom
KoP
Add a simple consistent hashing based load balancer implementation
pulsarctl
(#1711) fix code check
(#1704) feat: Subscription get message by id json output
(#1699) Update subscription get message by id typo lederId to ledgerId
StreamNative Pulsar Plugins
Fix deploy workflow
Fix deploy package workflow
Add plugin module deploy workflow
Function Mesh Worker Service
Use SN bom SNAPSHOT version
Do not allow using system topics when creating sink&source
Reject request when kafka connect’s name is longer than 29
Use SN bom to reduce artifact size
StreamNative Unified RBAC
Add lack sdk jar package and fix integration test
Use SN bom
StreamNative Ursa storage
[cleanup] Move the read cache into a single class
Clean up the unused code of ursa-storage-core
Remove the unused code
Use ubuntu-latest to run ci
Unity Catalog support clientId and clientSecret to authenticate.