Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Overview
This release adds beta functionality of JetStream simplified API. The goal of this API is to simplify and streamline stream and consumer management, as well as leverage pull consumers for continuous message retrieval. We encourage you to give it a try and post your feedback!
You can find more details on the new API here
Added
jetstream
directory (https://github.com/nats-io/nats.go/blob/main/jetstream/README.md) ([ADDED] JetStream Simplified API #1273 ).ConsumerName()
subscribe option to setName
inConsumerConfig
when creating a consumer (Add ConsumerName option, use similar ephemeral names as server #1263)SkipConsumerLookup()
subscribe option to bypass verifying if the consumer exists before consumer creation ([ADDED] SkipConsumerLookup option in js.Subscribe() #1265)Improved
micro
directory ([ADDED] README for micro package #1271)micro
(style: more intention-revealing microservice monitoring setup #1240)Changed
Subscribe()
when name is not provided to leverage 2.9.0 consumer create server API ([CHANGED] Generate consumer name in Subscribe() when name is not provided #1261, Add ConsumerName option, use similar ephemeral names as server #1263)micro
):api_url
andSCHEMA
endpoint (Remove SCHEMA endpoint and api_url #1270)Fixed
TestJetStreamConcurrentQueueDurablePushConsumers
test (Fix flaky TestJetStreamConcurrentQueueDurablePushConsumers test #1267)