Cosmic Predator
Cosmic Predator
> There is a pre50 nuget available. Be warned that this is a preview of the 2.0.0 release, which contains a bunch of breaking API changes. Seeing how you probably...
@Guillembonet this comment https://github.com/nats-io/nats.go/issues/1929#issuecomment-3234416936 + It seems like they already thought about this. https://github.com/ThreeDotsLabs/watermill-nats/blob/6e1bc30cf486162ba23630d078b7d3cd5562baaa/pkg/jetstream/consumer.go#L129
> > [@Guillembonet](https://github.com/Guillembonet) this comment [nats-io/nats.go#1929 (comment)](https://github.com/nats-io/nats.go/issues/1929#issuecomment-3234416936) + It seems like they already thought about this. > > https://github.com/ThreeDotsLabs/watermill-nats/blob/6e1bc30cf486162ba23630d078b7d3cd5562baaa/pkg/jetstream/consumer.go#L129 > > I think the todo is unrelated to this issue,...
> > > > [@Guillembonet](https://github.com/Guillembonet) this comment [nats-io/nats.go#1929 (comment)](https://github.com/nats-io/nats.go/issues/1929#issuecomment-3234416936) + It seems like they already thought about this. > > > > https://github.com/ThreeDotsLabs/watermill-nats/blob/6e1bc30cf486162ba23630d078b7d3cd5562baaa/pkg/jetstream/consumer.go#L129 > > > > > > >...
@Guillembonet I think this is an expected outcome. `Consume()` and `Messages()` are NATS Jetstream's `push` model where the first consumer that registers will pre-fetch all the messages from the queue....
> > [@Guillembonet](https://github.com/Guillembonet) I think this is an expected outcome. `Consume()` and `Messages()` are NATS Jetstream's `push` model where the first consumer that registers will pre-fetch all the messages from...
> **TL;DR:** before switching to fetch, tweak `PullMaxMessages` (lower it to single digits) and `AckWait`. > > Few clarifications: > > `Messages()` and `Consumer()` is `pull` and it doesnt mean...
@m110 I'm working on this. Thanks!