真实集群

kafka 0.9.x以后的版本不要使用 advertised.host.name 和 advertised.host.port 已经deprecate
第1台主机
  • docker-compose.yml
  1. version: '3.1'
  3. services:
  5.   kafka:
  6.     image: wurstmeister/kafka:2.12-2.1.0
  7.     restart: always
  8.     container_name: kafka
  9.     ports:
  10.       - "9092:9092"
  11.     volumes:
  12.       - /var/run/docker.sock:/var/run/docker.sock
  13.     environment:
  14.       KAFKA_BROKER_ID: 1
  15.       KAFKA_ZOOKEEPER_CONNECT: 121.43.162.28:2181,47.96.100.166:2181,118.24.136.237:2181
  16.       KAFKA_LISTENERS: PLAINTEXT://:9092
  17.       KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://121.43.162.28:9092
  20.   kafka-manager:
  21.     image: sheepkiller/kafka-manager:latest
  22.     container_name: kafka-manager
  23.     ports:
  24.       - "9000:9000"
  25.     environment:
  26.       ZK_HOSTS: 121.43.162.28:2181,47.96.100.166:2181,118.24.136.237:2181
  27.       APPLICATION_SECRET: letmein
  28.       KM_ARGS: -Djava.net.preferIPv4Stack=true
第2台主机
  • docker-compose.yml
  1. version: '3.1'
  3. services:
  5.   kafka:
  6.     image: wurstmeister/kafka:2.12-2.1.0
  7.     restart: always
  8.     container_name: kafka
  9.     ports:
  10.       - "9092:9092"
  11.     volumes:
  12.       - /var/run/docker.sock:/var/run/docker.sock
  13.     environment:
  14.       KAFKA_BROKER_ID: 2
  15.       KAFKA_ZOOKEEPER_CONNECT: 121.43.162.28:2181,47.96.100.166:2181,118.24.136.237:2181
  16.       KAFKA_LISTENERS: PLAINTEXT://:9092
  17.       KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://47.96.100.166:9092
  20.   kafka-manager:
  21.     image: sheepkiller/kafka-manager:latest
  22.     container_name: kafka-manager
  23.     ports:
  24.       - "9000:9000"
  25.     environment:
  26.       ZK_HOSTS: 121.43.162.28:2181,47.96.100.166:2181,118.24.136.237:2181
  27.       APPLICATION_SECRET: letmein
  28.       KM_ARGS: -Djava.net.preferIPv4Stack=true
第3台主机
  • docker-compose.yml
  1. version: '3.1'
  3. services:
  5.   kafka:
  6.     image: wurstmeister/kafka:2.12-2.1.0
  7.     restart: always
  8.     container_name: kafka
  9.     ports:
  10.       - "9092:9092"
  11.     volumes:
  12.       - /var/run/docker.sock:/var/run/docker.sock
  13.     environment:
  14.       KAFKA_BROKER_ID: 3
  15.       KAFKA_ZOOKEEPER_CONNECT: 121.43.162.28:2181,47.96.100.166:2181,118.24.136.237:2181
  16.       KAFKA_LISTENERS: PLAINTEXT://:9092
  17.       KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://118.24.136.237:9092
  20.   kafka-manager:
  21.     image: sheepkiller/kafka-manager:latest
  22.     container_name: kafka-manager
  23.     ports:
  24.       - "9000:9000"
  25.     environment:
  26.       ZK_HOSTS: 121.43.162.28:2181,47.96.100.166:2181,118.24.136.237:2181
  27.       APPLICATION_SECRET: letmein
  28.       KM_ARGS: -Djava.net.preferIPv4Stack=true
  • 查看kafka版本 
  1. find / -name \*kafka_\* | head -1 | grep -o '\kafka[^\n]*'