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 focuses on a set of changes and improvements in new JetStream API. With this release, JetStream API is out of preview.
Additionally, with this release support for go version < 1.18.0 is dropped, due to usage of
any
type in codebase.Added
HeadersOnly
field onOrderedConsumerConfig
([ADDED] HeadersOnly field on OrderedConsumerConfig #1327)WithStreamListSubject()
option to filter results ofListStreams()
andStreamNames()
by stream name ([CHANGED] Simplified API for listing streams and stream names, added option to filter by stream name #1312)Improved
dev
andmain
branches ofnats-server
to tests in CI (Adds nats-server dev + main branches to CI testing #1336)parse_test.go
([FIXED] Correct input for "parse 0" test case #1334)jetstream/README.md
(Fixes to jetstream/readme #1347, js: shorten timeout in readme #1350)Changed
interface{}
withany
across the codebase ([IMPROVED] Replace empty interface with any #1332)NakWithDelay
to separate method, instead of it being an option onNak()
([CHANGED] Move NakWithDelay to separate method #1337)context.Background()
orcontext.TODO()
is used ([CHANGED] Add default timeout in JetStream when empty context is used #1348)Fixed
OrderedConsumer()
(Create consumer on OrderedConsumer, add missing tests #1317)Next()
blocking indefinitely after callingStop()
(JetStream API: FixNext()
blocking indefinitely after callingStop()
#1344)Consume()
([FIXED] Invalid heartbeat errors in Consume() #1345)PublishAsync()
blocking published due toPublishAsyncMaxPending
not being reset on reconnect ([FIXED] PublishAsyncMaxPending not reset after server disconnect #1346)PublishAsync()
blocking published due toPublishAsyncMaxPending
not being reset on reconnect ([FIXED] PublishAsyncMaxPending not reset after server disconnect #1346)