1、下载Kafka安装包

下载地址

# 将压缩包移动到/usr/local/
mv kafka_2.12-3.1.0.tgz /usr/local/

# 解压
tar -zxvf kafka_2.12-3.1.0.tgz

2、启动

启动zookeeper

# 启动独立安装的zookeeper
./zkServer.sh start

# 也可以自动kafka自带的zookerper
./zookeeper-server-start.sh ../config/zookeeper.properties

启动kafka

cd /usr/local/kafka_2.12-3.1.0/bin

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

3、kafka交互

# 创建一个topic
./kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test

# 查看创建的topic
./kafka-topics.sh --bootstrap-server localhost:9092 --list

消息通信：

1. 启动kafka的服务端：

./kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test

2. 打开一个新的终端，进入kafka的bin目录，启动kafka的客户端：

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test

3. 发送消息
   

此时客户端终端接收到消息：

4、关闭kafka

# 关闭kafka
./kafka-server-stop.sh

# 关闭zookeeper
./zkServer.sh stop

5、Web UI kafdrop

下载地址

在IDE工具中使用maven打成jar包

启动命令（脚本）：

# startup.sh

java --add-opens=java.base/sun.nio.ch=ALL-UNNAMED -jar target/kafdrop-<version>.jar --kafka.brokerConnect=<host:port,host:port>,...

# restart.sh

ps -ef | grep kafdrop-3.29.0.jar | grep -v grep | awk '{print $2}' | xargs kill -9
rm -rf nohup.out
nohup ./startup.sh > nohup.out &

访问9000端口即可。