Skip to main content

​
StreamNative Weekly Release Notes v3.1.2.2

​
Download

​
Distributions

​
Packages

​
Images

​
General Changes

​
Apache Pulsar

[fix][broker] Fix issue with GetMessageIdByTimestamp can’t find match messageId from compacted ledger (#21600))) Revert “[fix][broker] Fix issue with GetMessageIdByTimestamp can’t find match messageId from compacted ledger [improve][ci] Upgrade pulsar-client-python to 3.4.0 to avoid CVE-2023-1428 [fix][broker] Fix issue with GetMessageIdByTimestamp can’t find match messageId from compacted ledger [fix][broker] Avoid consumers receiving acknowledged messages from compacted topic after reconnection [fix] [broker] Fix write all compacted out entry into compacted topic [fix] [broker] Replication stopped due to unload topic failed [fix][broker] Fix deadlock while skip non-recoverable ledgers. [fix][broker] Fix getMessageById throws 500 [fix][client] Fix multi-topics consumer could receive old messages after seek [fix] [broker] Fix reader stuck when read from compacted topic with read compact mode disable [improve] [proxy] Add a check for brokerServiceURL that does not support multi uri yet [fix][broker] Fix schema deletion error when deleting a partitioned topic with many partitions and schema [fix][broker] Correct schema deletion for parititioned topic [fix][client] Fix ConsumerBuilderImpl#subscribe silent stuck when using pulsar-client:3.0.x with jackson-annotations prior to 2.12.0 [fix] [broker] add timeout for health check read. [improve] [bk] Upgrade BookKeeper dependency to 4.16.4 [fix][test] Make base test class method protected so that it passes ReportUnannotatedMethods validation [fix][broker] Restore the broker id to match the format used in existing Pulsar releases [fix][broker] Fix leader broker cannot be determined when the advertised address and advertised listeners are configured [fix][broker] Fix returns wrong webServiceUrl when both webServicePort and webServicePortTls are set [fix][broker] Fix returns wrong webServiceUrl when both webServicePort and webServicePortTls are set [fix][broker] Fix PulsarService.getLookupServiceAddress returns wrong port if TLS is enabled (#21633))) Revert “[fix][broker] Fix returns wrong webServiceUrl when both webServicePort and webServicePortTls are set [fix][broker] Fix returns wrong webServiceUrl when both webServicePort and webServicePortTls are set

​
MoP

Fix broker enable dedup cause client publish msg NPE Add test for resubscribe Add filter system topic when using EventCenter Fix unsubscribe topic cause the test failed. call equals on formatted strings since they will never be null remove subs from subscription manager on unsubscribe

​
KoP

[transactions] Implement KIP-664 DescribeProducers

​
Cloud Storage Connector

fix: cleanup the current batch after flush crashed Update base image Update base image

​
AMQP1_0 Connector

Update base image

​
AWS SQS Connector

Update base image

​
AWS Lambda Connector

update-base-image

​
pulsarctl

Add method to mark bookie readonly Build arm64 linux executable binary artifact

​
StreamNative Pulsar Plugins

Upgrade Oxia Java Client to 0.1.1 Update Oxia to 0.0.10 e944ad01 Fix flaky test rest: Increase test await time fix test SNCompactionServiceTest [pulsar-detector] Fix wrong file name and line number in logs [pulsar-detector] Apply golangci-lint checks Add arm64 artifacts release Enhance find orphan ledger command.

​
Cloud Pulsar Plugins

[fix][sn-rbac] skip sn-rbac for adminTenants API Fix: return error future when JWT expired Fix: do not throws EX when calling AuthorizationProviderOAuth.isSuperUser

​
Function Mesh Worker Service

reduce integration test image size with slim base image clean up the disk bump function-mesh to 0.19.0 Ignore exception when connector customize catalogs is empty. Use oxia:0.2 image for testing

​
Google Pub / Sub Connector

Improve source connector docs. Improve sink connector docs. Add release image workflow

​
Google BigQuery Sink Connector

Update docker base

​
Snowflake Connector

Update base image