I know that when offsets get stored in Kafka, they get cleaned up based on the 
offsets.retention.minutes config setting. This happens when using the new 
consumer, or when using the old consumer but offsets.storage=kafka.

If using the old consumer where offsets are stored in Zookeeper, do old offsets 
ever get removed?

Thanks,
-James

Reply via email to