How to reset / revert Kafka offset of a consumer group used by Logstash?

Elastic Stack Logstash
1

Hi,

I am using Logstash GA 5.0.0 to read data from Kafka. For testing purposes, I need to re-run Logstash several times, and my Kafka topic has limited number of test messages. Everything works fine, but the problem is that I need to push new messages every time when I start Logstash, to work with it since the offset updates every time. Is there any way to reset this offset, so that every time I start Logstash, it start reading from the beginning of the topic?

Thank you.

2

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.