kafka基礎命令

2021-10-09 02:38:19 字數 1635 閱讀 6863

參考文章：

kafka版本：kafka_2.12-2.6.0

一、啟動zookeeper，cd 到kafka的根目錄執行以下：

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
加-daemon引數，可以在後台啟動zookeeper，輸出的資訊在儲存在執行目錄的logs/zookeeper.out檔案中。

二、關閉zookeeper，

bin/zookeeper-server-stop.sh -daemon config/zookeeper.properties
三、啟動kafka，cd到kafka根目錄，執行以下：

bin/kafka-server-start.sh -daemon config/server.properties
-daemon 引數會將任務轉入後台執行，輸出日誌資訊將寫入日誌檔案，日誌檔案在執行命令的目錄下的logs目錄中kafkaserver.out，結尾輸同started說明啟動成功。

四、停止kafka，執行以下：

bin/kafka-server-stop.sh config/server.properties
五、建立topic

bin/kafka-topics.sh --create --zookeeper 192.168.202.128:2181 --replication-factor 3 --partitions 3 --topic test
六、檢視主題

bin/kafka-topics.sh --list --zookeeper 192.168.202.128:2181
七、 傳送訊息，啟動kafka自帶的生產者，

bin/kafka-console-producer.sh --broker-list 192.168.202.128:9094 --topic test
八、消費訊息，啟動kafka自帶的消費者，

bin/kafka-console-consumer.sh --bootstrap-server 192.168.202.128:9092 --topic test --from-beginning
九、檢視特定主題，有哪些消費者組

bin/kafka-consumer-groups.sh --bootstrap-server 192.168.208.128:9092 --list
十、檢視消費組的消費情況

bin/kafka-consumer-groups.sh --describe --bootstrap-server 127.0.0.1:9092 --group usercenter
十

一、檢視某個主題資訊，192.168.202.128:2181是zookeeper位址，fxf是主題名稱。

bin/kafka-topics.sh --zookeeper 192.168.208.128:2181 --topic fxf --describe

kafka入門基礎命令

kafka啟動命令 bin kafka server start.sh 啟動命令 daemon 後台啟動引數 config server.properties 配置檔案 kafka語法 檢視主題個數 命令 bin kafka topics.sh list zookeeper hadoop01 218...

Kafka基礎 Kafka架構

目錄kakfa 架構 kafka最初是由linkedin公司採用scala語言開發的乙個多分割槽 多副本並且基於zookeeper協調的分布式訊息系統，現在已經捐獻給了apache 會。目前kafka已經定位為乙個分布式流式處理平台，它以 高吞吐 可持久化 可水平擴充套件 支援流處理等多種特性而被廣...

KAFKA基礎（一） KAFKA 概述

kafka 是乙個分布式的基於發布 訂閱模式的訊息佇列 message queue 主要應用於大資料實時處理領域。2.1傳統訊息佇列的應用場景 使用訊息佇列的好處 1 解耦 允許你獨立的擴充套件或修改兩邊的處理過程，只要確保它們遵守同樣的介面約束。2 可恢復性 系統的一部分元件失效時，不會影響到整個...