Open johanhaleby opened 7 months ago
It would be nice to be able to do e.g. like this:
subscriptions.subscribeAsync<MyEvent>("id") { ctx, e -> Thread.ofVirtual().start { log.info("Async") ctx.ack() } }
I.e. don't store position until ctx.ack() is called
ctx.ack()
It would be nice to be able to do e.g. like this:
I.e. don't store position until
ctx.ack()
is called