Reset consumer group offset

Reset consumer offsets to earliest

kafka-consumer-groups.sh --bootstrap-server kafka:9092 --group my-group --reset-offsets --to-earliest --topic my-topic --execute
tool
kafka20 commands
tags
kafka

More kafka commands

  • Produce messages from stdin
    kafka-console-producer.sh --bootstrap-server kafka:9092 --topic my-topic --property 'key.separator=:' --property 'parse.key=true'

    Produce key:value messages interactively

  • Consume from beginning
    kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic my-topic --from-beginning --max-messages 10

    Read first 10 messages from a topic

  • Alter topic partitions
    kafka-topics.sh --bootstrap-server kafka:9092 --alter --topic my-topic --partitions 12

    Increase partition count (cannot decrease)

  • Describe topic config
    kafka-configs.sh --bootstrap-server kafka:9092 --describe --entity-type topics --entity-name my-topic

    Show all overridden config values for a topic

  • Set topic retention
    kafka-configs.sh --bootstrap-server kafka:9092 --alter --entity-type topics --entity-name my-topic --add-config retention.ms=604800000

    Set 7-day retention on a topic

all 20 kafka commands