Release v1.41.0

[piotrpio]

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 (Consumer groups with Pinned and Overflow #1826)
  • WithDefaultTimeout option for JetStream API requests ([ADDED] DefaultTimeout option for JetStream API requests #1843

Fixed

• KeyValue:
  • Ensure timer is stopped when watcher is stopped ([FIXED] Ensure timer is stopped when watcher is closed #1838)
• ObjectStore:
  • Ensure object watcher stop closes the updates channel ([FIXED] Ensure object watcher stop closes the updates channel #1844)
• Core NATS:
  • Data race when reading current status in sub.StatusChanged and nc.StatusChanged ([FIXED] 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 ([FIXED] Reset channel after closing in ForceReconnect #1842, [FIXED] Initialize rqch channel for immediate reconnection on ForceReconnect #1846)

Changed

Improved

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

Signed-off-by: Piotr Piotrowski piotr@synadia.com

[coveralls]

coverage: 84.677% (+0.006%) from 84.671%
when pulling 376c12a on release/v1.41.0
into 9d1be03 on main.

[neilalexander]

LGTM