操练起来哟
一，zookeeper
docker run -d -p 2181:2181 --name zookeeper zookeeper
docker ps|grep zoo
7a153cd502c0 zookeeper "/docker-entrypoint.…" About an hour ago Up About an hour 2888/tcp, 3888/tcp, 0.0.0.0:2181->2181/tcp, :::2181->2181/tcp, 8080/tcp zookeeper
二，kafka
没弄官方的，网上很多文档也是基于这个kafka的docker。
docker run -d --name kafka \
-p 9092:9092 \
-e KAFKA_BROKER_ID=0 \
-e KAFKA_ZOOKEEPER_CONNECT=192.168.1.111:2181 \
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.1.111:9092 \
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka
查看相关的docker容器
[root@127 ~]# docker ps|grep zoo
7a153cd502c0 zookeeper "/docker-entrypoint.…" About an hour ago Up About an hour 2888/tcp, 3888/tcp, 0.0.0.0:2181->2181/tcp, :::2181->2181/tcp, 8080/tcp zookeeper
[root@127 ~]# docker ps|grep kafka
dffff21749af dushixiang/kafka-map:latest "java -Djava.securit…" 17 minutes ago Up 17 minutes 0.0.0.0:8089->8080/tcp, :::8089->8080/tcp kafka-map
1323f0ff60e3 wurstmeister/kafka "start-kafka.sh" 35 minutes ago Up 35 minutes 0.0.0.0:9092->9092/tcp, :::9092->9092/tcp kafka
忽略这个kafka-map，是下一节的内容.
三，进入容器，手工测试消息的生产和消费机制。
docker exec -it kafka /bin/bash
cd opt/bin
./kafka-console-producer.sh --broker-list localhost:9092 --topic sun
{"datas":[{"channel":"","metric":"temperature","producer":"ijinus","sn":"IJA0101-00002245","time":"1543207156000","value":"80"}],"ver":"1.0"}
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic sun --from-beginning
2022-03-20 16_57_30-MessageCenterUI.png
2022-03-20 16_57_12-MessageCenterUI.png
四，kafka要WEB管理，kafka-map就可以
docker run -d \
-p 8089:8080 \
-e DEFAULT_USERNAME=admin \
-e DEFAULT_PASSWORD=admin \
--name kafka-map \
dushixiang/kafka-map:latest
2022-03-20 17_17_24-MessageCenterUI.png
网友评论