kafka常用操作

2021-09-24 09:54:08 字數 768 閱讀 2299

1.開啟zookeeper命令(備註:先進入zookeeper的bin目錄)

./zkserver.sh start

2.關閉zookeeper命令(備註:先進入zookeeper的bin目錄)

./zkserver.sh stop

3.kafka啟動命令(備註:先進入kafka目錄)

常規模式啟動kafka

bin/kafka-server-start.sh config/server.properties

程序守護模式啟動kafka

nohup bin/kafka-server-start.sh config/server.properties >/dev/null 2>&1 & 

4.kafka關閉命令(備註:先進入kafka目錄)

bin/kafka-server-stop.sh

5.建立topic

bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic test1 --partitions 3 --replication-factor 1

6.啟動消費者

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

7.啟動生產者

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test1

kafka 常用操作

kafka支援的基本命令位於 bin資料夾中 常用命令 kafka topics.shkafka console consumer.shkafka console producer.sh kafka命令參考頁面 kafka 0.8.x 幫助文件 檢視topic列表 kafka topics list...

Kafka常用操作

1.kafka監控 kafka manager 2.啟動kafka 啟動zookeeper bin zkserver.sh start 開啟zk客戶端查詢 bin zkcli.sh server dsjcx1 2181,dsjcx2 2181,dsjcx3 2181 啟動kafka bin kafk...

kafka常用操作命令

broker kafka集群由乙個或多個伺服器組成。每個伺服器稱為 主題 topic 維護一組訊息分類 分割槽 partition 隸屬於主題,每個主題會包含多個分割槽,訊息 msg 隸屬於分割槽,每個分割槽有乙個訊息序列,每個訊息在該分割槽中都有乙個唯一的序號,這個序號叫偏移量 生產者 produ...