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

Reply via email to