深入解析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

注意事項

• 在啟動Kafka Broker之前，必須先啟動ZooKeeper伺服器。
• 在建立Topic之前，必須先啟動Kafka Broker。
• 在生產資料之前，必須先建立Topic。
• 在消費數據之前，必須先生產數據。
• 在停止Kafka叢集之前，必須先停止所有正在執行的Kafka Broker。
• 在停止ZooKeeper伺服器之前，必須先停止所有正在執行的Kafka Broker。

以上是深入解析Kafka啟動指令，迅速掌握Kafka的詳細內容。更多資訊請關注PHP中文網其他相關文章！