What I want is if the driver dies for some reason and it is restarted I
want to read only messages that arrived into Kafka following the restart of
the driver program and re-connection to Kafka.

Has anyone done this? any links or resources that can help explain this?

Regards
jk

Reply via email to