今天主要來介紹一些kafka的常用命令,記錄一下,便於平時使用:
1.kafka啟動: ./kafka-server-start.sh ../config/server.properties &
2.建立topic: ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic tes
3.檢視kafka的topic：./kafka-topics.sh --zookeeper master:2181 --list
4.檢視kafka某個topic下partition資訊: ./kafka-topics.sh --describe --zookeeper master:2181 --topic test-topic
5.檢視kafka的指定topic: ./kafka-topics.sh --zookeeper master:2181 --describe --topic yq20171220
6.控制台向kafka生產資料: ./kafka-console-producer.sh --broker-list master:9092 --topic jason_20180519
7.控制台消費kafka的資料: ./kafka-console-consumer.sh --zookeeper storm1:2181 --topic jason_20180519 --from-beginning
8.檢視topic下某分割槽偏移量的最小值: ./kafka-run-class.sh kafka.tools.getoffsetshell --topic test-topic --time -1 --broker-list master:9092 --partitions 0
9.增加topic的partition:/kafka-topics.sh --alter --topic jason_20180519 --zookeeper 10.200.10.24:2181,10.200.10.26:2181,10.200.10.29:2181 --partitions 5
10.刪除topic，慎用，只會刪除zookeeper中的元資料，訊息檔案須手動刪除: ./kafka-run-class.sh kafka.admin.deletetopiccommand --zookeeper master:2181 --topic yq20171220
11.徹底刪除topic: rmr /brokers/topics/【topic name】即可
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 ...