kafka主题与分区管理

主题

创建主题

1
bin/kafka-topics.sh --zookeeper localhost:2181/kafka --create --topic topic-demo --partitions 4 --replication-factor 1

查看单个主题信息

1
bin/kafka-topics.sh --zookeeper localhost:2181/kafka --describe --topic topic-demo

查看当前所有可用主题

1
bin/kafka-topics.sh --zookeeper localhost:2181/kafka -list

修改主题

将topic-demo分区数修改为3

1
bin/kafka-topics.sh --zookeeper localhost:2181/kafka --alter --topic topic-demo --partitions 3

删除主题

1
bin/kafka-topics.sh --zookeeper localhost:2181/kafka --delete --topic topic-create-api