1.安装zookeeper

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

2.安装kafka

docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=10.132.85.55:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://10.132.85.55:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka

-e KAFKA_BROKER_ID=0 配置当前kafka在kafka集群中的唯一ID
-e KAFKA_ZOOKEEPER_CONNECT=10.132.85.55:2181 配置zookeeper所在地址 此处使用IP地址
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://10.132.85.55:9092 设置对外访问的地址 此处使用IP地址
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 配置kafka的监听端口

3.创建主题

1.进入容器

docker exec -it ${CONTAINER ID} /bin/bash

2.进入kafka所在目录

cd /opt 

cd /kafka

3.创建主题

bin/kafka-topics.sh --create --zookeeper 10.132.85.55:2181 --replication-factor 1 --partitions 1 --topic mykafka

–zookeeper ${zookeeper地址:端口(2181)} 使用地址
–replication-factor ${副本数}
–partitions ${分区数}
–topic ${主题名}

4.发送消息

bin/kafka-console-producer.sh --broker-list 10.132.85.55:9092 --topic mykafka

–broker-list ${kafka集群中一个服务器:端口号(9092)} 使用地址
–topic ${主题名}

5.接收消息

bin/kafka-console-consumer.sh --bootstrap-server 10.132.85.55:9092 --topic mykafka

–bootstrap-server ${kafka集群中一个服务器:端口号} 使用地址
–topic ${主题名}

6.退出容器

exit