Hello, I am trying to understand how to cleanup offsets stored outside kafka. What I understand is that using ConsumerRebalanceListener, we can utilise storing/retrieving consumer offsets from external storage.
https://kafka.apache.org/23/javadoc/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html My question is - how do we do cleanup in the same way as kafka when deleting old offsets. For example, if I have been storing offsets 0-900, is there any strategy that can be followed to cleanup a chunk of old offsets? Or, is this not possible? Thanks,
