Changelog

Overview

This PR adds a PushConsumer implementation to jetstream, allowing easier migration to new API while maintaining usage of push consumers. For now it only supports the callback-based Consume(), more consuming options will be added in future releases.

ADDED

• Core NATS:
  • UserCredentialBytes() Conn option (#1877)
• JetStream:
  • PushConsumer implementation in jetstream package
  • Expose ClientTrace in JetStreamOptions (#1886)
• Service API:
  • Expose WithEndpointPendingLimits option (#1899)
• Legacy KeyValue:
  • Error() method to KeyLister and KeyWatcher interfaces (#1889)

FIXED

• Core NATS:
  • Fix timeoutWriter not recovering after first error (#1896)
• JetStream:
  • Consumer.Next() hangs after connection is closed (#1883)
  • Fixed stream info request for strict mode (#1887)
  • Ordered consumer not closing on connection close (#1885)
  • Return a more appropriate error when Subject Transform is not supported (#1416)
  • Fix subject transform comparison. Thanks @erikmansson for the contribution (#1907)
• Legacy JetStream:
  • Use timeout from JetStreamContext if no deadline is set on ctx (#1909)
• KeyValue:
  • Keys() and ListKeys() returning duplicates (#1884)
  • Fix subject prefix for the Create/Update operation in KV store. Thanks @SalvaChiLlo for the contribution (#1903)

CHANGED

• Change DefaultSubPendingMsgsLimit (#998)

Complete Changes

v1.43.0...v1.44.0