深入解析Kafka啟動指令，迅速掌握Kafka-java教程-PHP中文網

深入解析Kafka啟動指令，迅速掌握Kafka

WBOY

發布： 2024-02-01 09:44:14

原創

927 人瀏覽過

深入解析Kafka啟動指令，迅速掌握Kafka

Kafka啟動指令詳解

1. 啟動單一Broker

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

登入後複製

該指令將啟動一個Kafka Broker，並使用config/server .properties作為設定檔。

2. 啟動多個Broker

kafka-server-start.sh config/server-1.properties
kafka-server-start.sh config/server-2.properties
kafka-server-start.sh config/server-3.properties

登入後複製

該指令將啟動三個Kafka Broker，並使用config/server-1.properties、config/server -2.properties和config/server-3.properties作為設定檔。

3. 啟動ZooKeeper

zookeeper-server-start.sh config/zookeeper.properties

登入後複製

該指令將啟動一個ZooKeeper伺服器，並使用config/zookeeper.properties作為設定檔。

4. 建立Topic

kafka-topics.sh --create --topic test --partitions 3 --replication-factor 2

登入後複製

該指令將建立一個名為test的Topic，該Topic具有3個分割區和2個副本因子。

5. 生產資料

kafka-console-producer.sh --topic test

登入後複製

該指令將啟動一個控制台生產者，該生產者將資料傳送到test Topic。

6. 消費性資料

kafka-console-consumer.sh --topic test --from-beginning

登入後複製

該指令將啟動一個控制台消費者，該消費者將從test Topic的開頭開始消費資料。

7. 停止Kafka

kafka-server-stop.sh

登入後複製

該指令將停止所有正在執行的Kafka Broker。

8. 停止ZooKeeper

zookeeper-server-stop.sh

登入後複製

該指令將停止ZooKeeper伺服器。

具體程式碼範例

以下是一個完整的範例，示範如何啟動Kafka集群，建立Topic，生產數據，消費性數據，然後停止Kafka集群。

# 启动ZooKeeper
zookeeper-server-start.sh config/zookeeper.properties

# 启动Kafka Broker
kafka-server-start.sh config/server-1.properties
kafka-server-start.sh config/server-2.properties
kafka-server-start.sh config/server-3.properties

# 创建Topic
kafka-topics.sh --create --topic test --partitions 3 --replication-factor 2

# 生产数据
kafka-console-producer.sh --topic test

# 消费数据
kafka-console-consumer.sh --topic test --from-beginning

# 停止Kafka
kafka-server-stop.sh

# 停止ZooKeeper
zookeeper-server-stop.sh

登入後複製