kafka基本命令（速記）

2021-09-02 05:51:22 字數 2521 閱讀 1881

/usr/local/cellar/kafka/1.1.0 

（1.1.0版本目錄，請檢視自己版本對應的目錄號）

/usr/local/etc/kafka/server.properties

/usr/local/etc/kafka/zookeeper.properties

$    cd  /usr/local/cellar/kafka/1.1.0

$    ./bin/zookeeper-server-start  /usr/local/etc/kafka/zookeeper.properties  &

$    cd  /usr/local/cellar/kafka/1.1.0

$    ./bin/kafka-server-start  /usr/local/etc/kafka/server.properties  &

讓我們使用單個分割槽和只有乙個副本建立乙個名為「test」的主題

$    cd  /usr/local/cellar/kafka/1.1.0

$    ./bin/kafka-topics  --create  --zookeeper  localhost:2181  --replication-factor  1  --partitions  1  --topic  test

//kafka 中日誌儲存的時間設定 乙個小時後失效 防止硬碟沾滿

kafka-topics  --create  --zookeeper  39.98.51.253:2181  --replication-factor  1  --partitions  1  --topic  logdata  –alter –add-config retention.ms=1800000

終端列印資訊：createdtopic"test」.

我們現在可以看到該主題，如果我們執行list topic命令：

$    cd  /usr/local/cellar/kafka/1.1.0

$    ./bin/kafka-topics  --list  --zookeeper  localhost:2181

終端列印資訊：test

kafka/bin/kafka-topics.sh --delete --zookeeper zookeeper位址 --topic 主題名稱 

$    ./bin/kafka-topics --delete --zookeeper localhost:2181 --topic log

如果kafaka啟動時載入的配置檔案中server.properties沒有配置"delete.topic.enable=true"，那麼此時的刪除並不是真正的刪除，而是把topic標記為刪除：marked for deletion

kafka提供了乙個命令列客戶端，它將從檔案或標準輸入接收輸入，並將其作為訊息傳送到kafka集群。預設情況下，每行都將作為單獨的訊息傳送。

執行生產者，然後在控制台中鍵入一些訊息傳送到伺服器。

$    cd  /usr/local/cellar/kafka/1.1.0

第一種傳送方案（優選）：

$    ./bin/kafka-console-producer  --broker-list  localhost:9092  --topic  test

第二種傳送方案：

$    cd  libexec

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

(以上兩種方案回車後，任意輸入字元，可在消費者命令列檢視以下資訊)

>    第一條訊息

>    第二條訊息

kafka還有乙個命令列消費者，將訊息轉儲到標準輸出。

$    cd  /usr/local/cellar/kafka/1.1.0

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

kafka-console-consumer  --bootstrap-server  10.168.5.210:9092  --topic  alarm  --from-beginning

kafka-console-consumer  --bootstrap-server  10.168.5.210:9092  --topic  pointchange  --from-beginning

kafka 基本命令

建立topic bin kafka topics.sh create zookeeper localhost 2181 replication factor 1 partitions 1 topic test 檢視所有topic bin kafka topics.sh list zookeeper ...

kafka基本命令使用

本文主要參考 最近開始接觸kafka，下面介紹介紹一些最基本的kafka 的操作。首先是啟動kafka。kafka依賴zookeeper，所以需要先啟動zookeeper。bin zookeeper server start.sh config zookeeper.properties然後啟動kaf...

kafka2 5 0基本命令

本博文所使用kafka版本2.5.0，作業系統centos8.1 啟動zookeeper 演示用的話，直接啟動kafka自帶的zookeeper即可 cd kafkadirectory kafka 2.12 2.5.0 bin zookeeper server start.sh config zoo...