1.下载(/usr/local目录下)
下载地址：http://kafka.apache.org/downloads
wget http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/1.0.0/kafka_2.12-1.0.0.tgz
2.解压
tar -zxvf kafka_2.12-1.0.0.tgz
3.添加日志(/usr/local/kafka_2.12-1.0.0目录下)
mkdir logs
4.修改kafka配置文件(config目录下)
vi server.properties
broker.id=0
port=9092 #端口号
host.name=127.0.0.1 #服务器IP地址，修改为自己的服务器IP
log.dirs=/usr/local/kafka_2.12-1.0.0/logs/kafka-logs/
zookeeper.connect=localhost:2181
#zookeeper地址和端口，单机配置部署，localhost:2181
5.启动kafka(bin目录下)
./kafka-server-start.sh /usr/local/kafka_2.12-1.0.0/config/server.properties &
可根据ps -ef|grep kafka
6.关闭kafka(bin目录下)
# ./kafka-server-stop.sh
7.创建Topic：(创建一个名为test的topic，只有一个副本，一个分区。)(bin目录下)
#./kafka-topics.sh
--create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic test
8.列出所有Topic(bin目录下)：
./kafka-topics.sh -list -zookeeper 127.0.0.1:2181
9. 启动Producer并发送消息(bin目录下)：
10.启动Consumer并接收消息(bin目录下)：
./kafka-console-consumer.sh
--zookeeper 127.0.0.1:2181 --topic test --from-beginning
11.添加防火墙
sudo systemctl start firewalld.service 启动防火墙
firewall-cmd --add-port=9092/tcp 添加端口
firewall-cmd --reload 重启防火墙
10.阿里云添加mysql端口
入方向和出方向都添加mysql