操練起來喲
一剥懒,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
沒弄官方的猛拴,網(wǎng)上很多文檔也是基于這個(gè)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
查看相關(guān)的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
忽略這個(gè)kafka-map霞捡,是下一節(jié)的內(nèi)容.
三坐漏,進(jìn)入容器,手工測試消息的生產(chǎn)和消費(fèi)機(jī)制碧信。
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