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

sn-platform

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

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