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
