Maurice van Veen
Maurice van Veen
(not sure if limited to the simplified API, but it can be reproduced with it) Calling `drain(Duration.ZERO)` will wait indefinitely when a request timeout happened on a fetch. For this...
https://github.com/nats-io/jsm.go/pull/545 introduced checking if during a stream snapshot there was some sort of error. However `Nats-Request-Info` was checked which doesn't seem to contain this info. The server reports the header...
Currently it's possible for errors to occur during the creation of a stream backup, but they are not properly reported to the user. Making it look like the backup was...
- Increasing `reconnectWait` to wait a bit longer. A message put into the `reconnectOutgoing` queue will get immediately, regardless of this wait time. Only if we are stopped will we...
When `maxBatch`, `maxBytes`, `maxExpires` are exceeded there is only a timeout but no status message
### Observed behavior When setting `maxBatch`, `maxBytes` or `maxExpires` on the `ConsumerConfiguration`, and we exceed this value while pulling for messages, we don't get informed about this and only wait...
Resolves https://github.com/nats-io/nats.java/issues/1194 Simple potential fix is enabling `raiseStatusWarnings` in the `_pull(..)`. Would keep the behaviour the same, just informing the user of the status message being hit: ``` Aug 09,...
This PR implements an initial version for atomic/batch publishing, as described in [this ADR](https://github.com/nats-io/nats-architecture-and-design/pull/346). In general: - A client can now be implemented (given the current limitations listed below) to...
### Observed behavior When multiple `Nats-Msg-Id` are used within the same batch, and one `Nats-Msg-Id` is duplicate, the whole batch fails. This shouldn't be necessary, because a duplicate message is...
### Observed behavior R1 streams are not supported yet. The Raft log is used to ensure we can retry storing the batch if we get hard killed halfway through. A...
## Problem Statement The topic of immediate consistency within NATS JetStream can sometimes be a bit confusing. On our docs we claim we maintain immediate consistency (as opposed to eventual...