由于 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 查看
