1、檢視當前kafka伺服器中的所有topic
./kafka-topics.sh --list --zookeeper hadoop01:2181,hadoop02:2181
2、 使用命令列方式建立topic：
./kafka-topics.sh --create --zookeeper hadoop01:2181,hadoop02:2181 --replication-factor 2 --partitions 2 --topic general-ias-test1
引數說明：
--replication-factor : 表明 副本的個數， 這裡寫成2，表明會有兩個副本
--partitions : 表明會有兩個partition， 表現在log日誌中，就是是有兩個資料夾
3、檢視某個topic的詳情
./kafka-topics.sh --topic test --describe --zookeeper zk01:2181
4、為topic增加副本
./kafka-reassign-partitions.sh -zookeeper 127.0.0.1:2181 -reassignment-json-file json/partitions-to-move.json -execute
5、為topic增加partition
./kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --partitions 20 --topic testkj1
6、刪除topic
./kafka-topics.sh --delete --zookeeper hadoop01:2181,hadoop02:2181 --topic general-ias-test1
注意：需要server.properties中設定delete.topic.enable=true 否則只是標記刪除或者直接重啟。
./kafka-run-class.sh kafka.admin.deletetopiccommand --topic testkj1 --zookeeper hadoop01:2181
7、檢視consumer組內消費的offset
./kafka-run-class.sh kafka.tools.consumeroffsetchecker --zookeeper zk01:2181 --group testgroup
./kafka-run-class.sh kafka.tools.consumeroffsetchecker --zookeeper localhost:2181 --group test --topic testkj1
8、kafka服務啟動
./kafka-server-start.sh -daemon ../config/server.properties
9、下線broker
./kafka-run-class.sh kafka.admin.shutdownbroker --zookeeper 127.0.0.1:2181 --broker #brokerid# --num.retries 3 --retry.interval.ms 60
shutdown broker
10、kafka生產者客戶端命令
./kafka-console-producer.sh --broker-list localhost:9092 --topic testkj1
11、kafka消費者客戶端命令
./kafka-console-consumer.sh -zookeeper localhost:2181 --from-beginning --topic testkj1
12、通過shell命令傳送訊息
./kafka-console-producer.sh --broker-list kafka01:9092 --topic itheima
13、通過shell消費訊息
./kafka-console-consumer.sh --zookeeper zk01:2181 --from-beginning --topic test1
kafka常用命令
kafka常用操作命令 l檢視當前伺服器中的所有topic bin kafka topics.sh list zookeeper hadoop02 2181 l建立topic kafka topics.sh create zookeeper hadoop02 2181 replication fac...
kafka常用命令
啟動集群 nohup bin kafka server start.sh config server.properties 建立topic kafka topics topictt replication factor3 partitions3 create zookeeper hadoop1 21...
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 ...