watermill
watermill copied to clipboard
[watermill-nats] new jetstream API
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.
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.
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?