Docker快速搭建Kafka集群及测试的技术指南

docker search zookeeper      # 查看可用镜像
docker pull wurstmeister/zookeeper  # 拉取官方推荐镜像

docker run -d --name zookeeper \
  -p 2181:2181 \
  -t wurstmeister/zookeeper

docker search kafka --limit=50  # 查找镜像
docker pull wurstmeister/kafka  # 拉取镜像

# broker 0（端口9092）
docker run -d --name kafka0 \
  -p 9092:9092 \
  -e kafka_broker_id=0 \
  -e kafka_zookeeper_connect=xxx:2181 \
  -e kafka_advertised_listeners=plaintext://xxx:9092 \
  -e kafka_listeners=plaintext://0.0.0.0:9092 \
  wurstmeister/kafka

# broker 1（端口9093）
docker run -d --name kafka1 \
  -p 9093:9093 \
  -e kafka_broker_id=1 \
  -e kafka_zookeeper_connect=xxx:2181 \
  -e kafka_advertised_listeners=plaintext://xxx:9093 \
  -e kafka_listeners=plaintext://0.0.0.0:9093 \
  wurstmeister/kafka

# broker 2（端口9094）
docker run -d --name kafka2 \
  -p 9094:9094 \
  -e kafka_broker_id=2 \
  -e kafka_zookeeper_connect=xxx:2181 \
  -e kafka_advertised_listeners=plaintext://xxx:9094 \
  -e kafka_listeners=plaintext://0.0.0.0:9094 \
  wurstmeister/kafka

docker ps  # 应显示4个容器（1个zookeeper + 3个kafka）

# 进入任意kafka容器
docker exec -it kafka0 /bin/bash

# 进入脚本目录（注意版本号可能不同）
cd /opt/kafka_2.13-2.7.0/bin

# 启动生产者并创建test主题
./kafka-console-producer.sh \
  --broker-list localhost:9092 \
  --topic test

# 进入同一kafka容器
docker exec -it kafka0 /bin/bash

# 进入脚本目录
cd /opt/kafka_2.13-2.7.0/bin

# 启动消费者
./kafka-console-consumer.sh \
  --bootstrap-server localhost:9092 \
  --topic test \
  --from-beginning

./kafka-topics.sh --list --bootstrap-server localhost:9092

docker logs -f kafka0