https://www.jianshu.com/p/dca60ec57c5e

yum -y install java-1.8.0-openjdk-devel.x86_64

wget https://archive.apache.org/dist/kafka/0.10.2.1/kafka_2.11-0.10.2.1.tgz
tar -xzf kafka_2.11-0.10.2.1.tgz

mkdir -p /data/kafka
mv kafka_2.11-0.10.2.1  /data/kafka/

cd /data/kafka

cat <<'EOF' > /etc/systemd/system/zookeeper.service
[Unit]
Description=Apache Zookeeper service
Documentation=http://zookeeper.apache.org
Requires=network.target remote-fs.target
After=network.target remote-fs.target

[Service]
Type=simple
ExecStart=/data/kafka/kafka_2.11-0.10.2.1/bin/zookeeper-server-start.sh /data/kafka/kafka_2.11-0.10.2.1/config/zookeeper.properties
ExecStop=/data/kafka/kafka_2.11-0.10.2.1/bin/zookeeper-server-stop.sh
Restart=on-abnormal
WorkingDirectory=/data/kafka/kafka_2.11-0.10.2.1
Environment="_JAVA_OPTIONS=-Djava.net.preferIPv4Stack=true"     ##  开启IPv4

[Install]
WantedBy=multi-user.target

EOF

cat <<'EOF' > /etc/systemd/system/kafka.service
[Unit]
Description=Apache Kafka Service
Documentation=http://kafka.apache.org/documentation.html
Requires=zookeeper.service

[Service]
Type=simple
ExecStart=/data/kafka/kafka_2.11-0.10.2.1/bin/kafka-server-start.sh /data/kafka/kafka_2.11-0.10.2.1/config/server.properties
ExecStop=/data/kafka/kafka_2.11-0.10.2.1/bin/kafka-server-stop.sh
Environment="KAFKA_HEAP_OPTS=-Xmx2G"    ## 内存最大限制为 2G
Environment="KAFKA_OPTS=-Djava.net.preferIPv4Stack=True"    ## 启动IPv4


[Install]
WantedBy=multi-user.target

EOF

 配置 kafka 远程主机IP

cd /data/kafka/kafka_2.11-0.10.2.1/config &&  vim server.properties
## 取消如下两行的注释

listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://<HOST IP>:9092

systemctl daemon-reload
systemctl enable zookeeper kafka
systemctl start zookeeper kafka 

测试 ： 

## 发送消息
$  bin/kafka-console-producer.sh --broker-list localhost:9092 --topic DevOps

## 消费消息
$  bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic DevOps --from-beginning