基礎要求操作系統:CentOS 7x 64位 kafka版本:kafka_2.11-0.8.2.1
#安裝使用的jdk以及kafka的包我放到百度雲了,需要自取。
# 鏈接:https://pan.baidu.com/s/1k-Z0u09FRE_4bUbrePLStQ
提取碼:ns3c
1、關閉selinux 開放防火牆9092端口
[root@wzy-x ~]# vi /etc/selinux/config
[root@wzy-x ~]# tail -2 /etc/selinux/config
SELINUX=disabled
[root@wzy-x ~]# setenforce 0 #不重啟情況下臨時生效
[root@wzy-x ~]# getenforce #查看狀態
Permissive
開放防火牆9092端口
將jdk解壓到 /uer/local/src
解壓后改名為jdk方便后面使用
添加jdk到系統變量
應用到系統變量並查看jdk版本
上傳kafka到 /usr/local/src 下,並解壓
mkdir /usr/local/kafka ,將kafka移動到 /usr/local/kafka
#因為是單機安裝,所以不需要修改配置文件,保持默認
啟動zookeeper #啟動腳本在 /usr/local/kafka/kafka_.../bin/
啟動kafka
驗證kafka
cd /usr/local/kafka
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test #創建topic
驗證topic創建是否成功,成功輸出test。
模擬生產者發送消息
再開啟一個ssh連接,模擬消費者
至此服務就安裝成功了。