拉取zookeeker

docker pull wurstmeister/zookeeper

拉取kafka版本为2.12-2.2.0,不填写版本好则安装最新,但是个别系统会报错

docker pull wurstmeister/kafka:2.12-2.2.0

启动zookeeper

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

启动kafka

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

进入Kafka容器类kafka01是容器名称,也可以填写成容器ID

docker exec -it kafka01 /bin/bash

创建my_log topic

/opt/kafka/bin/kafka-topics.sh --create --zookeeper 192.168.153.141:2181 --replication-factor 1 --partitions 1 --topic my_log

查询创建的主题

/opt/kafka/bin/kafka-topics.sh --list --zookeeper 192.168.153.141:2181