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/shcd /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
选择版本下载 安装