Topic¶
topic 相关操作¶
# 创建 topic
./kafka-topics.sh --create --zookeeper localhost:2181/kafka --replication-factor 1 --partitions 1 --topic test
# 列出所有 topic
./kafka-topics.sh --zookeeper localhost:2181/kafka --list
# 查看 topic
./kafka-topics.sh --zookeeper localhost:2181 --describe --topic test
# 增加分区数量 (分区只能增加不能减少)
./kafka-topics.sh --zookeeper localhost:2181 --alter --topic test --partitions 4
# 删除 topic
./kafka-topics.sh --zookeeper localhost:2181 --delete --topic test