Docker 安装kafka

由于kafka需要zookeeper管理
docker run -d --restart=always --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime wurstmeister/zookeeper

开始安装

docker run -d --restart=always --name kafka -p 9092:9092 \
-e KAFKA_BROKER_ID=0 \
-e KAFKA_ZOOKEEPER_CONNECT=10.160.6.161:2181 \
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://10.160.6.161:9092 \
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka

测试安装结果

进入容器：docker exec -it kafka bash
切换到kafka可执行文件目录：/opt/kafka_2.13-2.8.1/bin/

创建一个名为 test 的 topic

./kafka-topics.sh --create --zookeeper 10.160.6.161:2181 --replication-factor 1 --partitions 1 --topic test

打开一个消费者监听消息

./kafka-console-consumer.sh --bootstrap-server 10.160.6.161:9092 --topic test --from-beginning

打开一个消息提供者

重新打开一个ssh窗口，进入容器，并切换到可执行文件目录
./kafka-console-producer.sh --broker-list 10.160.6.161:9092 --topic test

连接kafka测试Java代码

链接