kafka 命令列工具常用命令行操作

2. check命令

1.1 啟動kafka服務

zookeeper.connect:zookeeper連線設定ip:port

broker.id:啟動kafka的broker的id

1.2 建立topic

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

bin/kafka-console-producer.sh --broker-list host:9092 --topic topic

bin/kafka-console-consumer.sh --bootstrap-server host:9092 --topic topic --from-beginning

使用–list引數

bin/kafka-topics.sh --zookeeper host:2181 --list

使用–topic與–describe引數

bin/kafka-topics.sh --zookeeper host:2181 --topic your_topic --describe

使用–list引數

檢視consumer group列表有新、舊兩種命令，分別檢視新版(資訊儲存在broker中)consumer列表和老版(資訊儲存在zookeeper中)consumer列表，因而需要區分指定bootstrap–server和zookeeper引數：

bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server host:9092 --list

bin/kafka-consumer-groups.sh --zookeeper host:2181 --list

使用–group與–describe引數

同樣根據新/舊版本的consumer，分別指定bootstrap-server與zookeeper引數:

bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server host:9292 --group your_group_id --describe

bin/kafka-consumer-groups.sh --zookeeper host:2181 --group your_group_id --describe

是用於檢視指定topic上相應分割槽的訊息數，並不是consumer消費的偏移量

bin/kafka-run-class.sh kafka.tools.getoffsetshell --broker-list host:9092 --topic topic

Kafka 常用命令行工具

建立主題kafka topics.sh create zookeeper localhost 2181 replication factor 1 partitions 1 topic zjwblog 檢視所有主題kafka topics.sh zookeeper localhost 2181 lis...

Kafka命令列常用命令說明

基於0.8.0版本。bin kafka list topic.sh zookeeper 192.168.197.170 2181,192.168.197.171 2181 列出所有topic的分割槽情況 bin kafka list topic.sh zookeeper 192.168.197.17...

Kafka常用命令行總結

以下是kafka常用命令行總結 1.檢視topic的詳細資訊 kafka topics.sh zookeeper 127.0.0.1 2181 describe topic testkj1 2 為topic增加副本 kafka reassign partitions.sh zookeeper 127...