• 1.pull docker ,在机器上下载最新版本的kafka和zookeeper镜像,这里使用的是wurstmeister的镜像

      1. docker pull wurstmeister/kafka
      2. docker pull wurstmeister/zookeeper
    • 启动 zookeeper

      1. docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper
    • 启动kafka

      1. docker run -d name kafka1 -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.13.128:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.13.128:9092 -e KAFKA_LISTdocker run -d --name kafka1 -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.13.128:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.13.128:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka
      2. ENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka
    • 进入容器

      1. docker exec -it kafka1 bash

    启动集群第二个机器
    启动第二个kafka容器命名为kafka2,其zk地址与kafka1一致,broker_id为1,服务端口号为9093
    然后进入kafka容器创建第二个topic名为test2,副本数2,分区2

    1. docker run -d --name kafka2 -p 9093:9093 -e KAFKA_BROKER_ID=1 -e KAFKA_ZOOKEEPER_CONNECT=192.168.13.128:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.13.128:9093 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9093 -t wurstmeister/kafka

    参考:https://cloud.tencent.com/developer/article/2032059