Kafka connector should support offset . User function might want to process all the messages from 1. Beginning of a topic 2. From a particular value 3. From the latest value