I am working on a Kafka Consumer, and I am noticing it is consuming messages that should have been consumed 2 days ago. It repeats these messages roughly every 5 minutes, and the producer is no longer producing those messages for 2 days.
I have new data that should have been consumed, and the producer's logs show the new data is being produced and being sent to Kafka. But is not being consumed on the other side, it is just repeating the same data over and over again.
The Kafka application is built on top of Spring boot.
Edit: Producer runs every 10 minutes, and queries for any new data to send.
Update: I have increased the max.poll.interval.ms from 5 minutes to 1 hours. Currently it hasn't been an hour since I updated it, but I don't see it repeating data. But is there a way for me to get notified if the timeout occurred.
Update: I should point it, there are two kafka consumers, and I am seeing something about a partition being revoked.