1 拉取镜像

  1. docker pull wurstmeister/zookeeper
  2. docker pull wurstmeister/kafka

2 启动zookeeper

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

3 启动kafka

(1) 本地

172.21.133.148为本机局域网IP

  1. docker run --name kafka1 \
  2. -p 9092:9092 \
  3. -e KAFKA_BROKER_ID=0 \
  4. -e KAFKA_ZOOKEEPER_CONNECT=172.21.133.148:2181 \
  5. -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.21.133.148:9092 \
  6. -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \
  7. -d wurstmeister/kafka
  1. docker run --name kafka2 \
  2. -p 9093:9093 \
  3. -e KAFKA_BROKER_ID=1 \
  4. -e KAFKA_ZOOKEEPER_CONNECT=172.21.133.148:2181 \
  5. -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.21.133.148:9093 \
  6. -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9093 \
  7. -d wurstmeister/kafka

(2) 云服务器

  1. docker run --name kafka1 \
  2. -p 9092:9092 \
  3. -e KAFKA_BROKER_ID=0 \
  4. -e KAFKA_ZOOKEEPER_CONNECT=内网IP:2181 \
  5. -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://公网IP:9092 \
  6. -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \
  7. -d wurstmeister/kafka
  1. KAFKA_ADVERTISED_HOST_NAME:广播主机名称,一般用IP指定
  2. KAFKA_ZOOKEEPER_CONNECTZookeeper连接地址,格式:zoo1port1,zoo2:port2
  3. KAFKA_LISTENERSKafka启动所使用的的协议及端口
  4. KAFKA_ADVERTISED_LISTENERSKafka广播地址及端口,也就是告诉客户端,使用什么地址和端口能连接到Kafka
  5. KAFKA_BROKER_ID:指定BrokerId,如果不指定,将会自己生成

4 管理工具 kafka tool

https://www.kafkatool.com/download.html

  • 添加一个集群

image.png
image.png

  • 查看Brokers

image.png