Kafka常用的命令列值指令

1、hadoop集群啟動之後，啟動kafka

kafka-server-

start
.sh /opt/soft/kafka211/config/server.properties

2、建立kafka topic

kafka-topics.sh --create --zookeeper hosts:2181 --replication-factor 1 --partitions 1 --topic mydemo

replication-factor：副本備份數量

partitions：分割槽數量

topic：topic名稱

3、檢視已有的topic列表指定分割槽的資料條數

kafka-run-

class
.sh kafka.tools.getoffsetshell --time -1 --broker-list hosts:9092 --topic mymsg --partitions 0

topic：topic名稱

partitions：指定要檢視的是哪個分割槽

4、生產者操作頁面

kafka-console-producer.sh --broker-list hosts:9092 --topic mymsg

kafka-console-consumer.sh --bootstrap-server hosts:9092 --topic mymsg

//或者從頭開始讀
kafka-console-consumer.sh --bootstrap-server hosts:9092 --topic mytopic --
from
-beginning

6、刪除指定topic

kafka-topics.sh --delete --zookeeper hosts:2181 --topic mymsg

kafka-consumer-

group
.sh --bootstrap-server hosts:9092 --
group cm1 --reset-offsets --topic mymsg --to-earliest --execute

kafka-topics.sh --list --zookeeper hosts:2181

cmd命令列常用指令

新建資料夾和檔案 cd 返回上一級 md test 新建test資料夾 md d test my d盤下新建資料夾 cd test 進入test資料夾 cd.cc.txt 新建cc.txt檔案 dir 列出資料夾下所有檔案及資料夾 刪除資料夾和檔案 cd test 進入test資料夾 dir 檢視所...

kafka 命令列工具常用命令行操作

2.check命令 1.1 啟動kafka服務 zookeeper.connect zookeeper連線設定ip port broker.id 啟動kafka的broker的id 1.2 建立topicbin kafka topics.sh create zookeeper host 2181 r...

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 t...