kafka 命令列表

kafka 基於0.8.0版本的命令用法：

檢視topic分布情況kafka-list-topic.sh

# 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.170:2181,192.168.197.171:2181 --topic test （檢視test的分割槽情況）

其實kafka-list-topic.sh裡面就一句

exec $(dirname $0)/kafka-run-class.sh kafka.admin.listtopiccommand $@

實際是通過 kafka-run-class.sh指令碼執行的包kafka.admin下面的類

##建立topic kafka-create-topic.sh

# bin/kafka-create-topic.sh --replica 2 --partition 8 --topic test --zookeeper 192.168.197.170:2181,192.168.197.171:2181

建立名為test的topic， 8個分割槽分別存放資料，資料備份總共2份

# bin/kafka-create-topic.sh --replica 1 --partition 1 --topic test2 --zookeeper 192.168.197.170:2181,192.168.197.171:2181

結果 topic: test2 partition: 0 leader: 170 replicas: 170 isr: 170

##重新分配分割槽kafka-reassign-partitions.sh

這個命令可以分割槽指定到想要的--broker-list上

# bin/kafka-reassign-partitions.sh --topics-to-move-json-file topics-to-move.json --broker-list "171" --zookeeper 192.168.197.170:2181,192.168.197.171:2181 --execute

cat topic-to-move.json

],"version":1

}##為topic增加 partition數目kafka-add-partitions.sh

#bin/kafka-add-partitions.sh --topic test --partition 2 --zookeeper 192.168.197.170:2181,192.168.197.171:2181 （為topic test增加2個分割槽）

##控制台接收訊息

#bin/kafka-console-consumer.sh --zookeeper 192.168.197.170:2181,192.168.197.171:2181 --from-beginning --topic test

##控制台傳送訊息

# bin/kafka-console-producer.sh --broker-list 192.168.197.170:9092,192.168.197.171: 9092 --topic test

##手動均衡topic, kafka-preferred-replica-election.sh

# bin/kafka-preferred-replica-election.sh --zookeeper 192.168.197.170:2181,192.168.197.171:2181 --path-to-json-file preferred-click.json

cat preferred-click.json,,

,,,,

,]}##刪除topic,慎用，只會刪除zookeeper中的元資料，訊息檔案須手動刪除

# bin/kafka-run-class.sh kafka.admin.deletetopiccommand --topic test666 --zookeeper 192.168.197.170:2181 ,192.168.197.171:2181

kafka 命令列表

Kafka命令列操作

Kafka 命令列操作

Kafka命令列操作

kafka 命令列表

Kafka命令列操作

Kafka 命令列操作

Kafka命令列操作

相關推薦