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