Micronaut Kafka Listener : How to schedule kafka consumer poll() with 15 min interval

Question

I want to poll the topic once every 15 minutes. I found out there is a way to do this in kafka-spring with ConcurrentKafkaListenerContainerFactory and with below configuration

factory.getContainerProperties().setIdleBetweenPolls(900000);

Is there any similar configuration available for micronaut Kafka as well?

Answer 1

Not in a trivial way.

As of 4.3.0, it looks like Consumer.poll is being called in active loop without any delays (source).

But it looks like you can pause the consumer, so you might need to periodically do the pause-resume flipping in a separate job.

Caveat emptor from Kafka side: pausing the Micronaut Consumer does not interrupt the underlying poll (it's handled separately (source)).