Hello Kiran, Define old. In Kafka when you have a topic with: 1. cleanup.policy=delete - messages older than than the retention.ms will be deleted. For example - if you have a retention of 7 days, all messages older than 7 days will be deleted meaning the oldest message that you can recover is 7 days old. 2. cleanup.policy=compact - latest message for each key is retained, while the old messages are deleted. In this case you can recover old messages, but only the latest message for each key.
You can write a kafka consumer in a language of your choice, ensure the offset.reset policy is set to earliest. You can use console consumer as well as shown below to consume all messages (oldest to newest): kafka-console-consumer --bootstrap-server kafka:9092 --topic topic --from-beginning
