​
StreamNative Weekly Release Notes v2.11.0.3

​
Download

​
Distributions

​
Packages

​
Images

​
General Changes

​
Apache Pulsar

[improve][meta]Allow version to start positive and grow by more than one [fix][broker] Fix potential exception cause the policy service init fail. [fix] [broker] Topic close failure leaves subscription in a permanent fence state

​
Cloud Storage Connector

[chore] Upgrade to JDK 17 [feat][json] Allow NaN numbers when flag is set [fix][config] Fix NPE if partitionerType is empty [chore] upgrade transitive dependencies with severe vulnerabilities [chore] Rename io-cloud-storage-sink.md to cloud-storage-sink.md [fix][sink] Reset currentBatchSize & currentBatchBytes on failing records [fix][sink] Fix sink failing upon schema retrieval exceptions [docs] Add troubleshooting section to readme d9f4c4e Adjust codeowner to ecosystem [fix][schema] Fix Bytes schema conversion to AutoConsume schema [misc] Add @streamnative/ecosystem to CODEOWNERS Remove @streamnative/platform to avoid notification noise [#491 ]Fix flush stalling for large pendingQueueSize with small batchSize/maxBatchBytes [feat] Option to use message index instead of record sequence for partitioning [fix][ci] Change the release process [#20][docs] Update docs structure for pulsar-hub sync [#472][misc] Update PULL_REQUEST_TEMPLATE.md for auto-labeling [feat] Support for Azure Blob Storage Bump jackson-databind from 2.13.2.1 to 2.13.4.1 [misc] Bump checkstyle to 8.29 [feat] Make compression algorithm configurable for parquet format [misc] Move log ‘Skip flushing because the pending flush is empty’ to debug level [docs] Add pathPrefix to docs [config] Make pendingQueueSize default to batchSize [feat] Support for KeyValue schema [#445][sink] Add trigger for flushing batch when maxBatchBytes is reached [fix][sink] Fix multiple topics in the same output blob [fix][config] Validate endpoint URI scheme