以下是kafka常用命令行總結(jié)：
1.查看topic的詳細(xì)信息
./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消費(fèi)者客戶端命令
./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
