一、kafka單機安裝

1.下載 kafka_2.9.2-0.8.1.1.tgz

2.將檔案解壓

3.進入 kafka_2.9.2-0.8.1.1/config 目錄

4.修改 server.properties檔案

5.修改hosts檔案

vi /etc/hosts

192.168.178.129 zookeeper31
192.168.178.130 zookeeper32
192.168.178.131 zookeeper33

6.在kafka根目錄執行

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

7.建立topic 執行如下命令：

bin/kafka-topics.sh --create --zookeeper zookeeper31:2181 --replication-factor 1 --partitions 3 --topic mydemo1
 

8.檢視所有topic

bin/kafka-topics.sh --list --zookeeper zookeeper31:2181 --topic mydemo1

9.檢視topic詳細資訊

bin/kafka-topics.sh --describe --zookeeper zookeeperr31:2181 --topic mydemo1

10.停止kafka 程序

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

二、建立單機多Broker偽分散式

ddd

d引數111

1.複製server.properties 為 server1.properties,並修改如下內容

三、多機多Broker的配置

四、Kafka傳送訊息和接收訊息

1.傳送訊息

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

2.控制檯 接收訊息

bin/kafka-console-consumer.sh --zookeeper zookeeper31:2181 --topic mydemo1