watermill icon indicating copy to clipboard operation
watermill copied to clipboard

[watermill-nats] new jetstream API

Open AlexCuse opened this issue 1 year ago • 1 comments

Add a new pull subscribe option and target separately using eg https://natsbyexample.com/examples/jetstream/api-migration/go

I expect existing callback-based implementations will continue to work at least until v2 of the nats.go client is out. But batching pull subscribers should achieve better throughput in scenarios where order isn't terribly important.

AlexCuse avatar Jul 26 '23 01:07 AlexCuse

There are some changing semantics here. Eg queue groups are achieved through multiple pull subscriptions to the same broker-managed consumer. Maybe implementing as a separate PullSubscriber that has its own config makes sense to avoid any weirdness.

AlexCuse avatar Jul 26 '23 01:07 AlexCuse

Hey @AlexCuse .. wondering if you ever had any time to revisit this or if you have any other advice on going about setting up pull consumers?

mfreeman451 avatar Aug 02 '24 17:08 mfreeman451