在 docker下创建 kafka 服务端，并使用客户监听消息
由于 kafka 使用了 zookeeper 提供集群的服务注册发现，所以先要启动一个 zookeeper 容器
docker run -d --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime wurstmeister/zookeeper
然后开启一个 kafka 服务
docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=127.0.0.1:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka
这里要注意把 ip 换成你的服务器 ip 这时就可以打开客户端进行监听了
docker exec -it kafka /bin/sh
cd /opt/kafka_2.13-2.8.1/bin
bash kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --from-beginning --topic testtopic
上述参数分别代表：
-
–bootstrap-server: kafka服务地址 –from-beginning: 从头开始读取消息(如果想从特定地方开始需要设置 --offset, 重新监听新的消息则不加该参数) –topic: 指定要监听的 topic 更多参数使用 --help 查看
上一篇：
通过多线程提高代码的执行效率例子