How to reset the offset of messages consumed from Kafka?

0 votes

I have earlier consumed messages from Kafka. Now I want to reset the offset of consumer messages. I am using the following command:

kafka-consumer-groups.bat --bootstrap-server localhost:9092 --group group1 --reset-offsets --to-earliest --all-topics

So, I am getting output as the topic as, the partition number of topics and the new offset as 0.  But when I am executing the below command

kafka-consumer-groups.bat --bootstrap-server localhost:9092 --group group1 --describe

I can still see the old offset number. Anyone can help me in understanding how can I reset the offset?

Jul 9, 2018 in Apache Kafka by coldcode
• 2,050 points
4,653 views

1 answer to this question.

0 votes

The reset option only prints the result of the operation, but to perform the operation, you need to add --execute parameter to the command

kafka-consumer-groups.bat --bootstrap-server localhost:9092 --group group1 --reset-offsets --to-earliest --all-topics --execute

Hope this helps!

answered Jul 9, 2018 by Shubham
• 13,380 points

Related Questions In Apache Kafka

+1 vote
1 answer

Kafka consumer not able to start reading messages from the last uncommitted offsets

Hi@prasant, I am not sure it will work ...READ MORE

answered Feb 18 in Apache Kafka by MD
• 8,870 points
322 views
0 votes
1 answer

What is the optimum number of producers to create in Kafka?

In general, a single producer for all ...READ MORE

answered Jul 10, 2018 in Apache Kafka by nitinrawat895
• 10,870 points
2,257 views
0 votes
1 answer

Explain to me the functionality of Kafka in a Big-Data Cluster

Let me explain to you about Apache ...READ MORE

answered Apr 30, 2019 in Apache Kafka by ravikiran
• 4,600 points
201 views
0 votes
0 answers

How to check pending messages in KAFKA topic?

Let say we have first_topic which has kafka_server_brokertopicmetrics_messagesin_total{instance="localhost:1120",job="kafka",topic="first_topic"}  ...READ MORE

May 2, 2019 in Apache Kafka by anonymous
1,554 views
+1 vote
0 answers

Want to delete consumed topic programatically

directly delete kafka log folder and zeekeeper ...READ MORE

Jun 4, 2019 in Apache Kafka by sarvesh
222 views
+1 vote
10 answers

Writing the Kafka consumer output to a file

System.out.println(String.valueOf(output.offset()) + ": " + new String(bytes, ...READ MORE

answered Dec 7, 2018 in Apache Kafka by Harsh
11,308 views
0 votes
1 answer

How to commit message offsets in Kafka for reliable data pipeline?

You can use auto.commit.enable to allow Kafka ...READ MORE

answered Jul 9, 2018 in Apache Kafka by Shubham
• 13,380 points
608 views
+1 vote
12 answers

How can I delete all the messages from a Kafka topic?

As of kafka 2.3.0 version, there is ...READ MORE

answered Sep 8, 2019 in Apache Kafka by Brajkishore
• 240 points
73,452 views
0 votes
1 answer

Not able to fetch messages from Kafka cluster

You need to add the hostname in ...READ MORE

answered Jul 9, 2018 in Apache Kafka by Shubham
• 13,380 points
854 views