How to reset the offset for a kafka pipeline

Help Connectors and Pipelines
1

Is there a way to specify the kafka offset before a pipeline gets restarted ?

Basically ,do we have any similar options supported by the kafka-consumer command in singlestore to do the following :

  • reset offset to the latest message
  • reset offset from a datetime
  • reset offset to the earliest message

Thank you

2

Great questions. I’ll work on getting you an answer. Just out of curiosity, what kind of project are you working on?

3

Okay so I was given this article from our Developer Evangelist, Akmal. Give it a read. I hope that answers your question.

1 Like