Kafka命令行工具-kafka-topics

kafka-topics.sh 這是與主題(Topic)有關的命令行

Kafka命令行工具-kafka-topics

Kafka-topics的常用參數列表

使用示例

創建主題

 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,執行刪除命令並不會刪除,只是邏輯上標記為刪除


分享到:


相關文章: