要啟用 Consumer 去接收 Topic 的訊息，可調用 kafka-console-consumer.sh，帶入參數 –bootstrap-server 指定 Bootstrap server 位置、–topic 參數指定 Topic。 bin/kafka-console-consumer.sh --bootstrap-server [BootstrapServer] --topic [Topic] --from-beginning Link Apache Kafka

要使用 Kafka 發送訊息到指定的 Topic，可以調用 kafka-console-producer.sh，帶入參數 –broker-list 指定 broker 的位置、–topic 參數指定 topic。 bin/kafka-console-producer.sh --broker-list [Broker] --topic [Topic] Link Apache Kafka

要列出 Kafka 的 Topic，可以調用 kafka-topics.sh，帶入參數 –list 指示要列出 topic、–zookeeper 參數指定 ZooKeeper 位置。 bin/kafka-topics.sh --list --zookeeper [ZooKeeper] Link

要建立 Kafka 的 Topic，可以調用 kafka-topics.sh，帶入 –create 參數指定創建 topic、–zookeeper 參數指定 zookeeper 位置、–topic 參數指定要創建的 topic。 bin/kafka-topics.sh --create --zookeeper [ZooKeeper] --replication-factor [ReplicationFactor] --partitions [Partitions] --topic [Topic] Link Apache Kafka

要使用 Kafka 首先須確定環境中有安裝 Java。 若沒有的話需先進行安裝。 接著下載 Kafka 程式。 wget http://ftp.mirror.tw/pub/apache/kafka/2.0.0/kafka_2.11-2.0.0.tgz 將下載下來的 Kafka 程式解壓縮。 tar -xzf kafka_2.11-2.0.0.tgz 進入解壓縮後的 Kafka 目錄。 cd kafka_2.11-2.0.0 啟動 ZooKeeper。 bin/zookeeper-server-start.sh config/zookeeper.properties 啟動 Kafka。 bin/kafka-server-start.sh config/server.properties Link Apache Kafka