转 docker 部署 kafka
1、下载镜像
这里使用了wurstmeister/kafka和wurstmeister/zookeeper这两个版本的镜像
docker pull wurstmeister/zookeeper
docker pull wurstmeister/kafka
在命令中运行docker images验证两个镜像已经安装完毕
2、启动
1、启动zookeeper
docker run -d --name zookeeper -p 2181 -t wurstmeister/zookeeper
2、启动kafka
docker run --name kafka -e HOST_IP=localhost -e KAFKA_ADVERTISED_PORT=9092 -e KAFKA_BROKER_ID=1 -e ZK=zk -p 9092 --link zookeeper:zk -t wurstmeister/kafka
可以通过docker ps查看启动状态
3、测试发送消息
执行Docker ps,找到kafka的Container ID,进入容器内部:
docker exec -it ${CONTAINER ID} /bin/bash
进入kafka默认目录
cd opt/kafka_2.11-0.10.1.1/
下面就是跟一般的kafka没什么区别了
创建一个主题:
bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic mykafka
运行一个消息生产者,指定topic为刚刚创建的主题
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mykafka
运行一个消费者,指定同样的主题
bin/kafka-console-consumer.sh --zookeeper zookeeper:2181 --topic mykafka --from-beginning
这时在生产者输入测试消息,在消费者就可以接收消息了
----------
[1]在Docker上运行Apache Kafka[2]基于docker部署的微服务架构(五): docker环境下的zookeeper和kafka部署
转载于:https://www.cnblogs.com/telwanggs/p/10875736.html
转 docker 部署 kafka相关推荐
- docker部署kafka,k8s(helm)部署kafka
全栈工程师开发手册 (作者:栾鹏) 架构系列文章 我们在k8s上部署kafka,接收kafka生产者的数据,并将信息分发到消费者 kafka的基础知识参考:https://blog.csdn.net/ ...
- linux使用spotify/kafka 镜像docker部署 Kafka
Kafka 简介 作为一个消息中间件,Kafka 以高扩展性.高吞吐量等特点,在互联网项目中被广泛采用. Kafka 中文文档:https://kafka.apachecn.org/ kafka 安装 ...
- ubuntu用Docker部署kafka消息服务
** 为了方便后续的配置,以下部署的时候IP都统一使用同一个IP ** 首先,先下载两个官方images: docker pull wurstmeister/kafka docker pull wur ...
- Kafka之Docker部署Kafka kraft集群
最近趁着有空想复习一下Kafka原理,之前学的是Kafka1.9的版本,需要Zookeeper作为基础,专门存放Kafka的元数据使用,如Broker.Consumer.Topic等:但下载的时候发现 ...
- Docker部署Kafka
Docker安装Kafka 1.安装zookeeper docker run -d --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/local ...
- docker部署kafka,外部程序可以访问容器内的kafka
1. 编写docker-compose文件 zk_kafka.yml version: '2'services:zookeeper:image: hyperledger/fabric-zookeepe ...
- 【Kafka】3 Docker部署Kafka+ZooKeeper
Docker 推荐使用docker-compose构建环境脚本,方便修改以及同步. 新建文件 docker-compse.yml 1 安装 ZooKeeper version: "3&quo ...
- Docker 部署kafka遇到的问题
启动容器之后,状态为`Exited 如图, 查看日志 docker logs 1e1a55aa8d21 日志详细信息: [root@iZwz9geewjuo2sogidqn50Z ~]# docker ...
- Kafka:Docker Compose部署Kafka集群
创建目录用于存放Docker Compose部署Kafka集群的yaml文件: mkdir -p /root/composefile/kafka/ 写入该yaml文件: vim /root/compo ...
最新文章
- synchronized为可重入锁
- sharp扫地机器人讲话_扫地机机器人,智能扫地机器人推荐
- 2019信安国赛逆向easyGo,bbvvmm题解
- spring boot通过命令行配置属性
- 自定义控件——旋转菜单
- s5原生android 5.0,三星Galaxy S5升级Android 5.0:美味棒棒糖
- 【AtCoder】ARC095 E - Symmetric Grid 模拟
- 实现元素拖拽放大缩小_Vue实战067:DOM元素拖拽效果的实现
- 腾讯笔试:把两个数和告诉A,积告诉B,求这两个数是什么
- Redis学习笔记三:Redis的数据类型
- python三本经典书籍-有哪些 Python 经典书籍?
- Java面试宝典(超级详细)
- 全DIY主题+小工具 正版Win7桌面新体验windows7旗舰版主
- BZOJ3709 Bohater 贪心
- 互联网公司裁员潮传言四起,是捕风捉影还是确有其事?
- Python网络爬虫与信息提取(二):网络爬虫之规则(Requests库 Robots规则)
- 如何使用笔记本无线网卡创建无线热点?
- 智能硬件成在线教育救命稻草?
- Universal Termsrv.dll Patch 是个好东西
- thinkphp图片集合
热门文章
- 数据采集时总提示未登录_个税申报系统新功能!申报数据丢了也能找回!|税务局|个税|办税服务厅|纳税...
- ffmpeg视频处理
- (126)FPGA面试题-做了哪些FPGA时序约束?
- (34)System Verilog引用包中定义的类(失败)
- (36)System Verilog类中方法示例
- STM32编码器的学习笔记
- 6001. mavlink 编译与移植
- php判断值是否为空然后定义,判断php变量是不是定义,是否为空
- 利用python安装opencv_科学网—Anaconda Python PyCharm PyQT5 OpenCV PyTorch TF2.0 安装指南 - 张重生的博文...
- 【嵌入式Linux】嵌入式Linux应用开发基础知识之串口应用编程