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/zookeeper.properties

生產上建議連線到zookeeper集群，需更改配置檔案 config/server.properties 裡更改zookeeper配置zookeeper.connect=localhost:2181

2) 啟動kafka server

cd kafkadirectory/kafka_2.12-2.5.0

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

3) 主題topic

建立 test topic，乙個partitions分割槽，乙個replication-factor副本：

bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

列出topic：

bin/kafka-topics.sh --list --bootstrap-server localhost:9092

往test topic裡傳送資料：

bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test

從test topic裡面從頭開始消費資料：

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

更多kafka topic相關細節請移步至： 《kafka2.5.0 主題topic》

4） 本機搭建kafka集群

複製多個server.properties檔案：

cp config/server.properties config/server-1

.properties
cp config/server.properties config/server-2.properties

修改server-1.properties:

broker.id=1

listeners=plaintext://
:9093
log.dirs=/tmp/kafka-logs-9093

修改server-2.properties:

broker.id=2

listeners=plaintext://
:9094
log.dirs=/tmp/kafka-logs-9094

注意： broker.id 是每個節點唯一的id，並且永恆不變的。

5）檢視topic詳情

檢視topic詳情命令：

bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic test  // 命令輸出：

topic:testpartitioncount:1    replicationfactor:1 configs:

topic:testpartition: 0    leader: 0   replicas: 0 isr: 0

6）生產者傳送訊息

bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic my-replicated-topic

my test message 
1my test message 
2

7）消費者消費訊息

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

my test message 
1my test message 
2

end.

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...

kafka基本命令（速記）

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 cella...