Alter topic partitions

Increase (only) the number of partitions for a topic

kafka-topics.sh --bootstrap-server kafka:9092 --alter --topic <name> --partitions 6
tool
kafka20 commands
tags
kafka

More kafka commands

  • Get topic offsets
    kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list kafka:9092 --topic <name>

    Show earliest and latest offsets per partition

  • Create a topic
    kafka-topics.sh --bootstrap-server kafka:9092 --create --topic my-topic --partitions 6 --replication-factor 3

    Create a new Kafka topic with 6 partitions and RF=3

  • List consumer group lag
    kafka-consumer-groups.sh --bootstrap-server kafka:9092 --describe --group my-group

    Show per-partition lag for a consumer group

  • Reset consumer group offset
    kafka-consumer-groups.sh --bootstrap-server kafka:9092 --group my-group --reset-offsets --to-earliest --topic my-topic --execute

    Reset consumer offsets to earliest

  • 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

all 20 kafka commands