- 拉取kafka和zookeeper两个镜像
docker pull wurstmeister/zookeeper docker pull wurstmeister/kafka
2.启动zookeeper
docker run -it --name zookeeper -p 2181:2181 -d wurstmeister/zookeeper
3.启动kafka
docker run --name kafka01 -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_AUTO_CREATE_TOPICS_ENABLE=true -e KAFKA_ZOOKEEPER_ConNECT=49.235.224.114:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://49.235.224.114:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -d wurstmeister/kafka
参数说明
KAFKA_BROKER_ID： BROKER标识id
KAFKA_AUTO_CREATE_TOPICS_ENABLE： 自动创建topic
KAFKA_ZOOKEEPER_CONNECT： zookeeper地址
KAFKA_ADVERTISED_LISTENERS： 将Broker的Listener信息发布到Zookeeper中（配置外网ip访问kafka）
KAFKA_LISTENERS：定义Kafka Broker的Listener的配置项。
4.测试
进入kafka
docker exec it kafka01 /bin/sh cd /opt/kafka
创建主题
bin/kafka-topics.sh --create --zookeeper 公网ip:2181 --replication-factor 1 --partitions 1 --topic hello
查看主题列表：
bin/kafka-topics.sh --list --zookeeper 公网ip:2181
运行一个消息生产者，指定topic为刚刚创建的主题:
bin/kafka-console-producer.sh --broker-list 公网ip:9092 --topic hello
创建kafka消费者(这是新版本创建消费者,老版本是使用zookeeper)
bin/kafka-console-consumer.sh --bootstrap-server 公网ip:9092 --topic hello--from-beginning
5.kafka tools(可视化工具)
https://www.kafkatool.com/download.html
选择版本下载 安装
