kafka簡單的啟動命令

我這裡的安裝目錄是：/home/bigdata/kafka ， 節點名稱為 localhadoop1

進入安裝目錄後輸入

bin/kafka-server-start.sh config/server.properties &(後台執行)

bin/kafka-server-start.sh config/server.properties (執行)

啟動生產者模式

bin/kafka-console-producer.sh --broker-list localhadoop1:9092 --topic accesslog

消費者模式

bin/kafka-console-consumer.sh --zookeeper localhadoop1:2181 --from-beginning --topic mobile

建立topic

bin/kafka-topics.sh --create --zookeeper localhadoop1:2181 --replication-factor 1 --partitions 1 --topic mobile

檢視當前伺服器中的所有topic

bin/kafka-topics.sh --list --zookeeper localhadoop1:2181

檢視topic

sh kafka-topics.sh --topic test --describe --zookeeper localhadoop1 :2181

刪除topic

bin/kafka-topics.sh --delete --zookeeper localhadoop1:2181 --topic test

需要server.properties中設定delete.topic.enable=true否則只是標記刪除或者直接重啟。

**《kafka簡單的啟動命令》

kafka簡單的啟動命令

我這裡的安裝目錄是 home bigdata kafka 節點名稱為 localhadoop1 進入安裝目錄後輸入 bin kafka server start.sh config server.properties 後台執行 bin kafka server start.sh config ser...

kafka啟動命令

啟動 bin kafka server start.sh daemon config server.properties 建立主題 kafka topics.sh zookeeper s202 2181 topic calllog create replication factor 3 partit...

kafka啟動命令 Kafka入門

kafka是乙個高效能分布式訊息系統，今天就簡單介紹下基礎入門吧。tar xzf kafka 2.12 2.2.0.tgz cd kafka 2.12 2.2.0二 啟動伺服器kafka使用zookeeper，所以我們要先啟動zookeeper，可以使用安裝檔案裡面的啟動命令啟動乙個單節點的zook...