Kafka 0.11 how to reset offsets

by

By default, --reset-offsets just prints the result of the operation. To actually perform the operation you need to add --execute to your command:

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

More Related Contents:

  1. How to send final kafka-streams aggregation result of a time windowed KTable?
  2. Streamparse wordcount example
  3. Difference between session.timeout.ms and max.poll.interval.ms for Kafka >= 0.10.1
  4. Is there a way to purge the topic in Kafka?
  5. How does an offset expire for an Apache Kafka consumer group?
  6. How to commit manually with Kafka Stream?
  7. Increase the number of messages read by a Kafka consumer in a single poll
  8. Kafka how to read from __consumer_offsets topic
  9. How to change the number of replicas of a Kafka topic?
  10. Delete message after consuming it in KAFKA
  11. Understanding Kafka Topics and Partitions
  12. When to use RabbitMQ over Kafka? [closed]
  13. Delete topic in Kafka 0.8.1.1
  14. Kafka Stream Suppress session-windowed-aggregation
  15. Use Confluent Hub without Confluent Platform installation
  16. How to change start offset for topic?
  17. Connect to Kafka running in Docker
  18. How to install Kafka on Windows?
  19. Integrating Spark Structured Streaming with the Confluent Schema Registry
  20. How to create a Topic in Kafka through Java
  21. Java, How to get number of messages in a topic in apache kafka
  22. How to Delete a topic in apache kafka [duplicate]
  23. Is it possible to add partitions to an existing topic in Kafka 0.8.2
  24. In Apache Kafka why can’t there be more consumer instances than partitions?
  25. Kafka access inside and outside docker [duplicate]
  26. How to get kafka consume lag in java program
  27. Can i add topics to my @kafkalistener at runtime
  28. Handling exceptions in Kafka streams
  29. Is it possible to access message headers with Kafka Streams?
  30. How to decode/deserialize Avro with Python from Kafka

Leave a Comment