Feature Request: More Robust Reactive / Async Support for Periodic Offset Commits

[brianwyka]

I was reading over an article by Quarkus which discusses async consumers and when to commit offsets:
https://quarkus.io/blog/kafka-commit-strategies/

It seems that it is using SmallRye kafka connector behind the scenes, and recommends the throtttled strategy to achieve highest throughput with reactive consumers, while still guaranteeing that offsets committed periodically aren't accidentally done for records which haven't completed processing.

Currently, the only way to get this working in Micronaut is to use reactive types, but then to manually acknowledge each consumer record, which reduces the throughput and adds load to the broker, OR to use @Blocking on the consumer.