Skip to main content

StreamNative Weekly Release Notes v3.3.2.5

Download

Distributions

Packages

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