kafka常用命令簡介

topic生產

消費topic

查詢topic最新offset值

./bin/kafka-topics.sh --help

其中 --bootstrap-server --create 和 --topic 是三個必須提供的引數。

// kafka安裝目錄

./bin/kafka-topics.sh --bootstrap-server 192.167.0.1:9092,192.167.0.2:9092 --create --replication-factor 2 --partition 2 --topic user-test

replication-factor：用來設定主題的副本數

partition：用來設定主題的分割槽數

其中 --list 是必須提供的引數。

// kafka安裝目錄

./bin/kafka-topics.sh --bootstrap-server 192.167.0.1:9092,192.167.0.2:9092 --list

其中 --bootstrap-server --delete 和 --topic 是三個必須提供的引數。

// kafka安裝目錄

./bin/kafka-topics.sh --bootstrap-server 192.167.0.1:9092,192.167.0.2:9092 --delete --topic user-test

注意：需要在broker的配置檔案server.properties中配置 delete.topic.enable=true 才能真正刪除主題。

// 檢視命令相關引數

./bin/kafka-console-producer.sh --help

其中 --broker-list 和 --topic 是兩個必須提供的引數。

常用命令如下。

// 使用標準輸入方式

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

// 從檔案讀取：

./bin/kafka-console-producer.sh --broker-list 192.167.0.1:9092,192.167.0.2:9092 --topic test < file-input.txt

// 檢視命令相關引數

./bin/kafka-console-consumer.sh --help

其中 --bootstrap-server 和 --topic 是兩個必須提供的引數。

// kafka安裝目錄

./bin/kafka-console-consumer.sh --bootstrap-server 192.167.0.1:9092,192.167.0.2:9092 --topic user-test --from-beginning

from-beginning: 從未消費資料中最開始的地方消費

// 檢視命令相關引數

./bin/kafka-run-class.sh --help

其中 --broker-list 和 --topic 是兩個必須提供的引數。

// kafka安裝目錄

./bin/kafka-run-class.sh kafka.tools.getoffshell --broker-list 192.167.0.1:9092,192.167.0.2:9092 --topic user-test

查詢結果[topic:partition:offset]：

test-user:0:1:890

test-user:1:900

由此可以看出，test-user的topic分2個分割槽，每個分割槽中offset對應值為多少。