Alter topic partitions

Increase partition count (cannot decrease)

kafka-topics.sh --bootstrap-server kafka:9092 --alter --topic my-topic --partitions 12
tool
kafka20 commands
tags
kafka

More kafka commands

  • 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

  • Check broker metadata
    kafka-broker-api-versions.sh --bootstrap-server kafka:9092

    List all API versions supported by the broker

  • List topics
    kafka-topics.sh --bootstrap-server kafka:9092 --list

    List all Kafka topics in the cluster

  • Create topic
    kafka-topics.sh --bootstrap-server kafka:9092 --create --topic <name> --partitions 3 --replication-factor 2

    Create topic with specific partition and replication settings

all 20 kafka commands