How could I mimic a Kafka consumer missing consuming a message in Python

Is there an elegant way to test this - I have a Kafka Broker set up with two partitions and have a producer publish to both partitions (random). I have two consumers running with random sleep in between as threads and one is set to autooffset earliest and the other set to latest.

I am trying to mimic a scenario when the consumer set to latest will miss a message sent by the producer. And if this happens is there a way i can force the second consumer (earliest) to pick up that specific message missed instead of consuming the latest message ? And / or the first consumer (instead of being restarted) can be forced to find the offset that it missed?

https://stackoverflow.com/questions/66728390/how-could-i-mimic-a-kafka-consumer-missing-consuming-a-message-in-python March 21, 2021 at 10:48AM