kafka入門1：安裝及配置

1下載

官方下載地址：https://kafka.apache.org/downloads

案例使用版本：kafka_2.11-1.1.0.tgz

2上傳服務器

使用ftp工具將壓縮包放置到服務器上

案例放置位置爲 /root 下

3解壓

tar zxvf kafka_2.11-1.1.0.tgz

　　

4打開防火牆端口

2181：zookeeper 監聽端口，對cline端提供服務

9092：kafka server 監聽端口

5編輯kafka配置文件

1）進入kafka目錄

　　cd /root/kafka_2.11-1.1.0

2）編輯server.properties

　　vim config/server.properties

　　

3）在 「broker.id=0」 下添加
　　host.name=192.168.1.101（服務器IP地址）

　　

4）保存並退出編輯

6啓動

1）返回kafka目錄

　　cd /root/kafka_2.11-1.1.0

2）啓動zookeeper

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

3）啓動kafka

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

7測試

1）建立名爲 testKafka 的topic

　　　bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testKafka

　　

2）查詢當前全部 topic 

 　　bin/kafka-topics.sh --list --zookeeper localhost:2181

　　

3）啓動一個消費者

　　bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic testkafka

　　

　　

4）啓動一個生產者

　　bin/kafka-console-producer.sh --broker-list 192.168.1.101:9092 --topic testkafka

　　

5）測試

　　生產者啓動後會進入命令行模式，如今能夠在輸入信息測試消費者是否能夠接收到了

　　

　　消費者