Kafka 常用命令

kafka-console-producer --broker-list 127.0.0.1:9092 --topic mytopic

kafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic mytopic

建立主題,replication-factor副本數量，partitions分割槽數量

kafka-topics --zookeeper 127.0.0.1:2183/kafkaconnect --create --topic mytopic --replication-factor 3 --partitions 9

主題列表

kafka-topics --zookeeper 127.0.0.1:2183/kafkaconnect --list

主題詳細描述

kafka-topics --zookeeper 127.0.0.1:2183/kafkaconnect --describe

修改partitions數到10個

kafka-topics --zookeeper 127.0.0.1:2183/kafkaconnect --alter --topic mytopic --partitions 10

顯示不同步分割槽

kafka-topics --zookeeper 127.0.0.1:2183/kafkaconnect --describe --under-replicated-partitions

顯示所有的消費者群組

kafka-consumer-groups --bootstrap-server 127.0.0.1:9092 --list

消費者群組 詳細資訊

kafka-consumer-groups --bootstrap-server 127.0.0.1:9092 --group mygroup --describe

刪除消費者群組

kafka-consumer-groups --zookeeper 99.48.236.97:2183/kafkaconnect --delete --group mygroup