nats-io/nats.go v1.41.0

Release v1.41.0

on GitHub

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