StreamNative Weekly Release Notes v3.3.5.12

General Changes

Apache Pulsar

(#24626) [fix][proxy] Fix TooLongFrameException with Pulsar Proxy (#24621) [fix][broker] Fix duplicate watcher registration after SessionReestablished (#24610) [fix][client]Prevent ZeroQueueConsumer from receiving batch messages when using MessagePayloadProcessor (#24606) [improve][broker]Remove block calling that named cursor.asyncGetNth when expiring messages (#24604) [improve][io] Add dependency file name information to error message when .nar file validation fails with ZipException (#24601) [improve][doc] Improve the JavaDocs of sendAsync to avoid improper use (#24599) [fix][client] Retry for unknown exceptions when creating a producer or consumer (#24450) [fix][broker] Fix REST API to produce messages to single-partitioned topics (#24595) [fix][ci] Fix code coverage metrics in Pulsar CI (#24582) [improve][client] Support load RSA PKCS#8 private key (#24535) [improve][test] Add test for dead letter topic with max unacked messages blocking (#24532) [fix][misc] Upgrade dependencies to fix critical security vulnerabilities (#24514) [improve][build] Bump org.apache.commons:commons-lang3 from 3.17.0 to 3.18.0 (#24586) [improve][test] Refactor the way way pulsar-io-debezium-oracle nar file is patched when building the test image (#24590) [fix][broker] Fix flaky testReplicatorsInflightTaskListIsEmptyAfterReplicationFinished

KoP

451a59b88 [branch-3.3] Bump version to 3.3.5.12 Fix possible deadlock of system topic access due to blocking call when holding the lock Fix incorrect ListOffsets result on a compacted topic

Function Mesh Worker Service

747a4e68 Update MeshWorkerServer bb788d1e Fix version Support set agent tools config Make MeshWorker able to run standalone and load additional servlets Support load ConnectorCatalog using label Update error msg in status

StreamNative Tiered storage

Run tests

StreamNative Unified RBAC

fix(misc): add some logs and missing output Update package.json feat: upgrade sdk-go to 0.13 feat: support Acls on Pulsar feat: support allPartition macros and fix a compatibility issue feat: upgrade dependencies feat: support ACL specification feat(sdk-go-cloud): upgrade the sdk-go to 0.11.0 [feat] Extend functions&connectors permissions feat(sdk-java): add some debugging logs Update package.json fix(wasm): fix csp fix(sdk-go): fix compatibility issue as #466 fix: upgrade dependencies && fix project CI fix(sdk-java): compatible with legacy request condition Update package.json feat(wasm): refine result code fix(wasm): fix compile error Update package.json fix(wasm): remove debugging logs feat(wasm): standardise API Update package.json feat(wasm): upgrade the dependencies to avoid wasm panic feat(sdk-go): move k8s related dependencies to cloud feat: move document to wiki Update package.json Update ci-publish-js.yaml feat(sdk-js): refine the public API fixes(sdk-js): fixes the missing dependency protobuf fix(sdk-js): fix CI workflow 2 fix: fix the CI golang building feat: support sdk-js based on wasm fix(test): fix testing docker image build script fix(sdk-java): fix empty condition missing SRN validation feat: upgrade sdk-go version to 0.9.0 fix: avoid empty cel mess up authorization logic feat: upgrade dependencies fix(sdk-go): fix the empty condition ignore SRN Use GET_BUNDLE operation to check the “get” permission for namespace feat(sdk-go-*): upgrade dependencies fix(sdk-go): support authorizer missing method feat: downgrade golang version feat(sdk-go-cloud): upgrade dependencies feat: support macros on condition feat: update dependencies feat: support resource name based conditions Update ci: service-accout-admin -> account-admin feat(ci): Notify in slack when CI failed feat(sdk-go-cloud): upgrade sdk-go to 0.7.2 Add Kafka topics delete permission feat(sdk-go-cloud): upgrade sdk-go to 0.7.1 feat(sdk-go): kafka cel support Update test cluster location feat(sdk-go-cloud): upgrade sdk-go to 0.7.0 Reduce rbac filter timeout to 3 seconds by default and make it configurable Fix kafka permission format Add permission format rule Use RoleBinding name to save bindings in metadata Add KSN permissions Add cv tests for service-account-admin and secret-viewer Upgrade project and sdk/java to 1.6.0 Add kafka condition Support batch apply role bindings Run CV tests in parallel mode Create test clusters dynamically for CI feat(sdk-go-cloud): upgrade sdk-go to 0.6.0 Add ServiceAccount, ApiKey and Secret to SRN Use Github package wildcard repository url Change the cluster used in integration test Optimize logic of list filter interceptor fix: remove annoying logs Do not create temp cloud resources in CI Add lack sdk jar package and fix integration test Add more cloud tests Use SN bom Add packages, produce, consume tests feat(sdk-go-cloud): upgrade sdk-go to 0.5.0 feat(metadata): support cloud resource volumes and catalogs Add more cloud tests feat(sdk-go-cloud): upgrade the sdk-go to 0.4.1 feat(metadata): generate metadata for all sdk feat: GetPrivileges support for sdk-go-cloud feat(sdk-go): support pivileges validation feat: introduce new permission cloud.selfOrganizations.alter feat(sdk-js): upgrade sdk to 0.0.9 to support new permission feat: upgrade project and sdk-java, sdk-pulsar to 1.5.0 feat(sdk-go-cloud): upgrade sdk-go to v0.3.0 Skip rbac reconcile for PulsarInstances create in CI Add Pool/PoolOption/PoolMember tests