Hello, I have a Spark source producing to Kafka, and a Java consumer. The consumer was shutdown for around a week while the producer was active. Now when the consumer is active, it is fetching messages from 7 days back.
I would like to ignore the older messages, and start from the latest one. How do I do it ? This is for version 0.8.2.1. Please share your suggestions. Regards, Saurav