StreamNative Weekly Release Notes v2.11.0.3

Download

[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

[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