ToDo Tasks Allow event offset to be reset? Handle dead letters? Test that restarting the connector (or even just kafka connect) doesn't result in re-ingesting from the beginning of the event feed