StreamNative Weekly Release Notes v3.3.2.5

Download

Distributions

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

Packages

Maven Central

Images

General Changes

Apache Pulsar

[improve][admin] Opt-out of topic-existence check

[fix][broker] Catch exception for entry payload interceptor processor

[fix][cli] Fix set-retention with >2GB size value for topic policy

[fix][cli] Fix set topic retention policy failed

[fix] [broker] Add consumer name for subscription stats

[improve] Install coreutils in docker image to improve compatibility

[fix][broker] Invoke custom BrokerInterceptor's onFilter method if it's defined

[fix][broker] support missing cluster level fine-granted permissions

[feat][broker] Implement allowBrokerOperationAsync in PulsarAuthorizationProvider to avoid exception thrown

[fix][broker] support missing tenant level fine-granted permissions

[fix][broker]: support missing broker level fine-granted permissions

f792b02794 Bump version to next snapshot version

[improve][broker] Skip unloading when bundle throughput is zero (ExtensibleLoadManagerImpl only)

[improve][client] Enhance error handling for non-exist subscription in consumer creation

[fix][client] Fix race-condition causing doReconsumeLater to hang when creating retryLetterProducer has failed

[improve][client] Reduce unshaded dependencies and shading warnings in shaded Java client modules

[improve] Upgrade OpenTelemetry library to 1.44.1 version

[improve][client] Replace NameUtil#generateRandomName with RandomStringUtils#randomAlphanumeric

[fix][build] Fix error "Element encoding is not allowed here" in pom.xml

[fix][client] Fix DLQ producer name conflicts when there are same name consumers

[improve] Upgrade oxia-java to 0.4.10 and fix closing of OxiaMetadataStore

[fix][client] Fix deadlock of NegativeAcksTracker

[improve][broker] Decouple pulsar_storage_backlog_age_seconds metric with backlogQuota check

[fix][client] Make protobuf-java dependency optional in java client libraries

[improve] Use single buffer for metrics when noUnsafe use

[fix][broker] fix null lookup result when brokers are starting

[fix][client] Fixed an issue where a cert chain could not be used in TLS authentication

[improve][misc] Disable OTel by default when running the pulsar-perf tool

[cleanup][build] skip generating pom.xml.versionsBackup

[fix][client] Initializing client-authentication using configured auth params

[fix][misc] Class conflict during jetcd-core-shaded shading process

[fix][ws] Implement missing http header data functions in AuthenticationDataSubscription

KoP

Add pulsar-kafka-schema-registry jar to image

Cloud Storage Connector

aeb2c91 code format

479f01b [fix] fix wrong call to bulkHandleFailedRecords

Exist connector process when encounter exception

StreamNative Pulsar Plugins

bump pulsar 3.3.2.5

Change authentication failed log level to warn

Cloud Pulsar Plugins

Allow accepting token from query parameters

Function Mesh Worker Service

Add extraDependency field to FunctionMeshConnectorDefinition

Support set pod annotations via CustomRuntimeOptions

Google BigQuery Sink Connector

Optimize getGoogleCredentials exception

StreamNative Tiered storage

iceberg catalog suit the polaris catalog.

Upgrade aws dependency to 2.x

StreamNative Unified RBAC

feat(sdk-go-cloud): upgrade sdk-go to 0.1.16

feat(sdk-go): schema cel support

disable permission check to get better compatibility

feat(sdk-java): upgrade version to 1.3.0

upgrade sdk to 0.1.15

feat: support schema permissions

Add schema permissions

feat(sdk-go-cloud): support role cache to avoid io call

feat(sdk-java-pulsar): support missing computing component permissions

feat(sdk-go-cloud): upgrade sdk-go to version 0.1.14

fix(sdk-go): avoid filter the permissions for application role

feat(cv): support binding with cel

build(deps): bump nanoid from 3.3.7 to 3.3.8 in /sdk/sdk-js

fix(cv): fix the private repo visibility

feat(cv): support integration test

feat(sdk-go-cloud): upgrade sdk-go to 0.1.12

ci: fix CI to make sure test passed

fix(sdk-go-x): filter pulsar service admin permission

feat(sdk-apiserver): support sdk-apiserver

feat(sdk-java-pulsar): Implement broker rbac filter

feat(sdk-go-cloud): upgrade sdk

fix(ci): fix CI failed by wrong packet name

feat: upgrade the pulsar to snapshot repo

fix(sdk-js): fix the JSON format

feat(sdk-js): support permission cube

feat: support cluster,tenant,broker level permissions

upgrade the project version to 1.2.0

fix(sdk-js): upgrade the version to 0.0.4

refine the metadata specification

fix(sdk-java): fix failed integration test

feat(java): release 1.1.0

feat(pom): upgrade version to 1.1.0-snaphsot

Feat.improve.publish

feat(sdk-java): publish java to github packages

feat(sdk-java): improve the condition authorization interface

fix(sdk-go-cloud): fix wrong subject comparing

fix(sdk-go-cloud): fix undecoded service account subject

feat(metadata): support new permissions for cloud metrics

upgrade sdk js version

fix types import

feat: support CLI for unified rbac read endpoints

fix: fix proto decode issue

feat(sdk-js): support NewAuthorizerWithPrivilegesString

feat: upgrade sdk-go proto

feat(sdk-js): update proto definition

feat(sdk-go-cloud): upgrade sdk-go to 0.1.8

feat(sdk-go): upgrade schema

feat(sdk-js): support privileges authorizer

feat: make proto pojo json to camel case

fix: fix sdk-js name

feat: upgrade node version to 20

feat(doc): add document for unified-rbac

feat: support sdk-js

Security Fixes

Apache Pulsar

[fix][sec] Bump commons-io version to 2.18.0