以下是kafka常用命令行總結(jié)：

1.查看topic的詳細信息

./kafka-topics.sh?-zookeeper127.0.0.1:2181-describe?-topic?testKJ1

2、為topic增加副本

./kafka-reassign-partitions.sh?-zookeeper127.0.0.1:2181-reassignment-json-file?json/partitions-to-move.json?-execute

3、創(chuàng)建topic

./kafka-topics.sh?--create?--zookeeper?localhost:2181--replication-factor1--partitions1--topic?testKJ1

4、為topic增加partition

./bin/kafka-topics.sh?–zookeeper127.0.0.1:2181–alter?–partitions20–topic?testKJ1

5、kafka生產(chǎn)者客戶端命令

./kafka-console-producer.sh?--broker-list?localhost:9092--topic?testKJ1

6、kafka消費者客戶端命令

./kafka-console-consumer.sh?-zookeeper?localhost:2181--from-beginning?--topic?testKJ1

7、kafka服務(wù)啟動

./kafka-server-start.sh?-daemon?../config/server.properties

8、下線broker

./kafka-run-class.sh?kafka.admin.ShutdownBroker?--zookeeper127.0.0.1:2181--broker?#brokerId#?--num.retries3--retry.interval.ms60

shutdown?broker

9、刪除topic

./kafka-run-class.sh?kafka.admin.DeleteTopicCommand?--topic?testKJ1?--zookeeper127.0.0.1:2181