Skip to content

Release v2.1.5
Compare
Choose a tag to compare
@wallyqs wallyqs released this 15 Aug 22:12
· 306 commits to main since this release
v2.1.5
4269801
This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
GPG key ID: 4AEE18F83AFDEB23
Expired
Learn about vigilant mode.

Added

  • Added pending_msgs_limit and pending_bytes_limit can now be set for push and pull consumers from JetStream. To disable limits -1 can be used instead:
# Push Subscriber
await js.subscribe("push-example", pending_bytes_limit=-1, pending_msgs_limit=-1)

# Pull Subscriber
await js.pull_subscribe("pull-example", "durable", pending_msgs_limit=-1, pending_bytes_limit=-1)
  • Added sub.pending_bytes and sub.pending_msgs methods to confirm buffered bytes and messages from a Subscription

Fixed

  • Fixed accounting bug when using sub.next_msg which would have caused SlowConsumer errors and dropping messages when reaching default limit

  • Fixed empty message being returned sometimes when calling sub.next_msg after future was cancelled

Assets 2
Loading