StreamNative Weekly Release Notes v3.1.2.2

Download

Distributions

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

Packages

Maven Central

Images

General Changes

Apache Pulsar

(#21600) [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

(#21899) [improve][ci] Upgrade pulsar-client-python to 3.4.0 to avoid CVE-2023-1428

(#21600) [fix][broker] Fix issue with GetMessageIdByTimestamp can't find match messageId from compacted ledger

(#21187) [fix][broker] Avoid consumers receiving acknowledged messages from compacted topic after reconnection

(#21917) [fix] [broker] Fix write all compacted out entry into compacted topic

(#21947) [fix] [broker] Replication stopped due to unload topic failed

(#21915) [fix][broker] Fix deadlock while skip non-recoverable ledgers.

(#21919) [fix][broker] Fix getMessageById throws 500

(#21945) [fix][client] Fix multi-topics consumer could receive old messages after seek

(#21969) [fix] [broker] Fix reader stuck when read from compacted topic with read compact mode disable

(#21972) [improve] [proxy] Add a check for brokerServiceURL that does not support multi uri yet

(#21977) [fix][broker] Fix schema deletion error when deleting a partitioned topic with many partitions and schema

(#21574) [fix][broker] Correct schema deletion for parititioned topic

(#21985) [fix][client] Fix ConsumerBuilderImpl#subscribe silent stuck when using pulsar-client:3.0.x with jackson-annotations prior to 2.12.0

(#21990) [fix] [broker] add timeout for health check read.

(#21983) [improve] [bk] Upgrade BookKeeper dependency to 4.16.4

(#21976) [fix][test] Make base test class method protected so that it passes ReportUnannotatedMethods validation

(#21937) [fix][broker] Restore the broker id to match the format used in existing Pulsar releases

(#21894) [fix][broker] Fix leader broker cannot be determined when the advertised address and advertised listeners are configured

(#21842) [fix][broker] Fix returns wrong webServiceUrl when both webServicePort and webServicePortTls are set

(#21633) [fix][broker] Fix returns wrong webServiceUrl when both webServicePort and webServicePortTls are set

(#21015) [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

(#21633) [fix][broker] Fix returns wrong webServiceUrl when both webServicePort and webServicePortTls are set

MoP

(#1246) Fix broker enable dedup cause client publish msg NPE

(#1224) Add test for resubscribe

(#1219) Add filter system topic when using EventCenter

(#1223) Fix unsubscribe topic cause the test failed.

(#1211) call equals on formatted strings since they will never be null

(#957) remove subs from subscription manager on unsubscribe

KoP

(#382) [transactions] Implement KIP-664 DescribeProducers

Cloud Storage Connector

(#824) fix: cleanup the current batch after flush crashed

(#874) Update base image

(#873) Update base image

AMQP1_0 Connector

(#808) Update base image

AWS SQS Connector

(#836) Update base image

AWS Lambda Connector

(#772) update-base-image

pulsarctl

(#1257) Add method to mark bookie readonly

(#1328) Build arm64 linux executable binary artifact

StreamNative Pulsar Plugins

(#1504) Upgrade Oxia Java Client to 0.1.1

(#1353) Update Oxia to 0.0.10

e944ad01 Fix flaky test

(#1493) rest: Increase test await time

(#1485) fix test SNCompactionServiceTest

(#1453) [pulsar-detector] Fix wrong file name and line number in logs

(#1445) [pulsar-detector] Apply golangci-lint checks

(#1410) Add arm64 artifacts release

(#1373) Enhance find orphan ledger command.

Cloud Pulsar Plugins

(#965) [fix][sn-rbac] skip sn-rbac for adminTenants API

(#945) Fix: return error future when JWT expired

(#924) Fix: do not throws EX when calling AuthorizationProviderOAuth.isSuperUser

Function Mesh Worker Service

(#1195) reduce integration test image size with slim base image

(#1187) clean up the disk

(#1152) bump function-mesh to 0.19.0

(#1174) Ignore exception when connector customize catalogs is empty.

(#1170) Use oxia:0.2 image for testing

Google Pub / Sub Connector

(#609) Improve source connector docs.

(#608) Improve sink connector docs.

(#607) Add release image workflow

Google BigQuery Sink Connector

(#479) Update docker base

Snowflake Connector

(#310) Update base image