Consuming Kafka Topic with Apache Camel and Spring Boot

[@arjunav612]

Hi, I have a doubt please reply, I have a kafka consumer with .pausable(), My kafka producer produces messages every 2 second. I have . Everytime i consume a message i increment a counter, so my ,pausable() condition is like if count

[@anbuzhobbiez]

You can schedule a method to run every 4-5 mins and check the beginning and end offsets of the partition and seek, poll them.
As you are consuming and increasing the counter this will not work.