操练起来哟

一，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