安装 kafka 需要先安装 jdk。
一、下载
官网：
http://kafka.apache.org/downloads.html
二、安装
安装参考：
https://segmentfault.com/a/1190000012990954
1. 解压安装（我的安装目录/opt/kafka/）
# tar -zvxf kafka_2.11-2.1.0.tgz
2. 修改配置
# vim /opt/kafka/kafka_2.11-2.1.0/config/server.properties
3. 修改其中
listeners=PLAINTEXT://ip:9092
注：ip指的是本机ip地址
三、验证
1. 使用安装包中的脚本启动单节点Zookeeper实例：
# cd /opt/kafka/kafka_2.11-2.1.0
# bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
2. 使用kafka-server-start.sh启动kafka服务：
# bin/kafka-server-start.sh config/server.properties
3. 使用kafka-topics.sh 创建但分区单副本的topic test
# bin/kafka-topics.sh –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test
4. 使用kafka-console-producer.sh 发送消息
# bin/kafka-console-producer.sh –broker-list localhost:9092 –topic test
5. 使用kafka-console-consumer.sh 接收消息并在终端打印
# bin/kafka-console-consumer.sh –bootstrap-server localhost:9092 –topic test –from-beginning
四、配置开机自启（systemctl）
1. 在 /lib/systemd/system/ 目录下创建 zookeeper服务和kafka服务 的配置文件。
# vim zookeeper.service
zookeeper.service 添加内容：
[Unit]
Description=Zookeeper service
After=network.target[Service]
Type=simple
Environment=”PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin:/opt/java/jdk-11.0.1/bin”
User=root
Group=root
ExecStart=/opt/kafka/kafka_2.11-2.1.0/bin/zookeeper-server-start.sh /opt/kafka/kafka_2.11-2.1.0/config/zookeeper.properties
ExecStop=/opt/kafka/kafka_2.11-2.1.0/bin/zookeeper-server-stop.sh
Restart=on-failure[Install]
WantedBy=multi-user.target
# vim kafka.service
kafka.service 添加内容：
[Unit]
Description=Apache Kafka server (broker)
After=network.target zookeeper.service[Service]
Type=simple
Environment=”PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin:/opt/java/jdk-11.0.1/bin”
User=root
Group=root
ExecStart=/opt/kafka/kafka_2.11-2.1.0/bin/kafka-server-start.sh /opt/kafka/kafka_2.11-2.1.0/config/server.properties
ExecStop=/opt/kafka/kafka_2.11-2.1.0/bin/kafka-server-stop.sh
Restart=on-failure[Install]
WantedBy=multi-user.target
注：以上两个文件 根据自己的 jdk 和 kafka 安装目录相应的修改。
2. 刷新配置。
# systemctl daemon-reload
3. zookeeper、kafka服务加入开机自启。
#systemctl enable zookeeper
#systemctl enable kafka
4. 使用systemctl启动/关闭/重启 zookeeper、kafka服务systemctl start/stop/restart zookeeper/kafka。
注：启动kafka前必须先启动zookeeper 。
# systemctl start zookeeper
# systemctl start kafka
5. 查看状态。
# systemctl status zookeeper
# systemctl status kafka
完工！！！