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,020 points
2,716 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,300 points

Related Questions In Apache Kafka

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,710 points
1,561 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 in Apache Kafka by ravikiran
• 4,560 points
89 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 in Apache Kafka by anonymous
687 views
0 votes
1 answer

Re-balancing error while reading messages from Kafka.

rebalance.backoff.ms defines the time for which Kafka ...READ MORE

answered Jul 9, 2018 in Apache Kafka by Shubham
• 13,300 points
545 views
0 votes
0 answers

Want to delete consumed topic programatically

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

Jun 4 in Apache Kafka by sarvesh
123 views
0 votes
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
7,740 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,300 points
366 views
0 votes
1 answer

Is Kafka and Zookeeper are required in a Big Data Cluster?

Apache Kafka is one of the components ...READ MORE

answered Mar 22, 2018 in Big Data Hadoop by nitinrawat895
• 10,710 points
432 views
0 votes
12 answers

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

Add one line to server.properties file under ...READ MORE

answered Nov 27, 2018 in Apache Kafka by Lavanya
42,888 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,300 points
603 views