Added
- Added
pending_msgs_limit
andpending_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
andsub.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