欢迎您访问365答案网,请分享给你的朋友!
生活常识 学习资料

docker安装kafka

时间:2023-05-02
拉取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/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

选择版本下载 安装

Copyright © 2016-2020 www.365daan.com All Rights Reserved. 365答案网 版权所有 备案号:

部分内容来自互联网,版权归原作者所有,如有冒犯请联系我们,我们将在三个工作时内妥善处理。