kafka-topics.sh 這是與主題(Topic)有關的命令行
使用示例
創建主題
bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic test --partitions 3 --replication-factor 3
注:replication-factor 副本系數不能大於 broker 的數量
描述主題的詳細信息
bin/kafka-topics.sh --zookeeper localhost:2181 --topic test --describe
列出主題
bin/kafka-topics.sh --zookeeper localhost:2181 --list
修改主題
示例一
將上面創建的主題的分區是 3,增加 5 個分區,命令如下:
bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic test --partitions 8
示例二
給指定的主題添加配置項,如下:
bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic test --config max.message.bytes=128000
刪除主題
bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test
注:刪除命令受 conf/server.properties 配置中的 delete.topic.enable 選項影響:
- 如果為 true,執行刪除命令會將主題給刪除
- 如果為 false,執行刪除命令並不會刪除,只是邏輯上標記為刪除
閱讀更多 走了關門的耳朵 的文章