Skip to content

Release v1.41.0

Choose a tag to compare

View all tags
@piotrpio piotrpio released this 03 Apr 14:13
· 144 commits to main since this release
v1.41.0
e040f71
This commit was created on GitHub.com and signed with GitHub’s verified signature.
GPG key ID: B5690EEEBB952194
Verified
Learn about vigilant mode.

Changelog

Overview

This release adds consumer priority groups to JetStream, exposing overflow and pinning policies. For more information on consumer priority groups, see ADR-42.

Added

  • JetStream:
    • Consumer priority groups with pinned and overflow policies (#1826)
    • WithDefaultTimeout option for JetStream API requests (#1843)

Fixed

  • KeyValue:
    • Ensure timer is stopped when watcher is stopped (#1838)
  • ObjectStore:
    • Ensure object watcher stop closes the updates channel (#1844)
  • Core NATS:
    • Data race when reading current status in sub.StatusChanged and nc.StatusChanged (#1841)
    • Reset channel after closing in ForceReconnect to avoid panic on subsequent ForceReconnect calls (#1842, #1846)

Changed

Improved

  • Legacy JetStream:
    • Cancel Fetch and FetchBatch on reconnect (#1840)
  • JetStream:
    • Invalid default in documentation for OrderedConsumerConfig.InactiveThreshold (#1845)
  • KeyValue:
    • Stop the watcher before performing the purge operations for PurgeDeletes (#1839)

Complete Changes

v1.40.1...v1.41.0

Assets 2
Loading