kafka zookeeper docker容器互联
1、build dockerfile
kafka dockerfile
zookeeper dockerfile
2、镜像启动
//-h 指定hostname
sudo docker run -itd --name zookeeper -h zookeeper -p 2181:2181 jiankunking/zookeeper:3.4.6
//-h 指定hostname
//--link 容器可以通过link链接进行访问,这样就不需要指定ip了
sudo docker run -itd --name kafka -h kafka -p 9092:9092 --link zookeeper jiankunking/kafka:0.8.2.2
3、查看kafka、zookeeper端口是否已被监听
//kafka
lsof -i:9092
//zookeeper
lsof -i:2181
也可以进入kafka、zookeeper容器查看相应端口是否已经被监听。
4、启动kafka
//进入容器
sudo docker exec -it d1361270a323 /bin/bash
//切换目录
cd /opt/kafka/kafka_2.11-0.8.2.2/bin/
//创建topic
./kafka-topics.sh --create --topic test1 --zookeeper zookeeper:2181 --partitions 3 --replication-factor 1
如果提示:
/opt/kafka/kafka_2.11-0.8.2.2/bin/kafka-run-class.sh: line 155: exec: java: not found
则刷新配置文件:
source /root/.bash_profile
//再创建一个topic test2
./kafka-topics.sh --create --topic test2 --zookeeper zookeeper:2181 --partitions 3 --replication-factor 1
Created topic "test2".
//查看创建的topic信息
./kafka-topics.sh --zookeeper zookeeper:2181 --describe --topic test1
./kafka-topics.sh --zookeeper zookeeper:2181 --describe --topic test2
//查看topic列表
./kafka-topics.sh --list --zookeeper zookeeper:2181
启动kafka消费端:
./kafka-console-consumer.sh --zookeeper zookeeper:2181 --topic test1
再一个新的shell窗口,进入容器,启动kafka producer
./kafka-console-producer.sh --broker-list localhost:9092 --topic test1
启动后,在kafka producer中输入内容回车,kafka consumer就会收到了
作者:jiankunking 出处:http://blog.csdn.net/jiankunking
kafka zookeeper docker容器互联相关推荐
- docker容器互联实战
2019独角兽企业重金招聘Python工程师标准>>> docker容器互联实战 转载于:https://my.oschina.net/xiejunbo/blog/811768
- Docker 容器互联 --link 和 自定义网络
[Docker那些事]系列文章 Dockerfile 文件结构.docker镜像构建过程详细介绍 Dockerfile文件中CMD指令与ENTRYPOINT指令的区别 构建Docker镜像指南,含实战 ...
- 5. Docker容器互联1--Docker存储原理和基于Docker Volum的容器互联
目录 Docker 容器互联 1 基于Docker Volum的容器互联 1.1 Docker的文件存储 1.2Docker Volume 1.3 数据容器共享解决方案(volumes-form) ...
- docker容器互联
link方式 http://blog.csdn.net/halcyonbaby/article/details/42112325 通过link方式创建容器,然后我们可以使用被link容器的别名进行访问 ...
- 【kafka】kafka jmx docker 容器下 跨容器连接 没有到主机的路由 host unreachable
文章目录 1.概述 1.概述 我的一个程序,程序的内容是topic消息入栈速率 但是有些环境是可以的,有些环境是不可以的.报错如下 下面我打印的日志:连接 kafkanode1:34567 没有成功. ...
- Docker多台宿主机间的容器互联-centos7
如果要在生产和测试环境大规模采用docker技术,首先就需要解决不同物理机建的docker容器互联问题.本文介绍在centos7环境下采用open vswitch实现不同物理服务器上的docker容器 ...
- Docker网络---容器互联
前言: 虽然每个docker容器之间都能通过ip来进行互联,但当容器重新启动,ip就会被重新分配给重新启动的容器,这时同个容器由于重启导致ip不一样了,这时就会导致开发和运维的困难程度大大增加,这时候 ...
- 容器云系列之Docker网络管理及容器互联
Docker网络有bridge.host.overlay.macvlan和none五种模式,本文对这几种网络模式进行验证并测试容器间的互联通信. 1.Docker网络管理 Docker有5种网络模式, ...
- weave实现宿主机之间的容器互联
weave实现宿主机之间的容器互联 Docker Weave简介 关于weave的原理不做细致的说明,如果想了解weave可以登陆官网:https://www.weave.works/ 注意:防火墙一 ...
- 运维之道 | Docker 容器连接
Docker 容器连接 前面我们实现了通过网络端口来访问运行在 docker 容器内的服务. 容器中可以运行一些网络应用,要让外部也可以访问这些应用,可以通过-P或-p参数来指定端口映射. 下面我们来 ...
最新文章
- SAP QM 执行事务代码QS23为检验特性分配Selected Set的时候报错 - You cannot use entries from catalogs 1 and 3-
- 巧用Dictionary实现日志数据批量插入
- 开年趣图汇总:对不起,让你笑了这么久
- 金山云和金山办公均成功上市 雷军揭秘背后原因
- Car-like Robot运动参数分析
- A Simple Math Problem (矩阵快速幂)
- linux 下网站压力测试工具webbench
- TVS管与稳压二极管的区别
- 三种近距离通信技术(WIFI、蓝牙、NFC)
- VHDL三段式状态机
- 医疗管理核心制度之 十八、信息安全管理制度
- 大陆身份证号码正则验证js脚本
- 写个单机版斗地主程序,复习c++面向对象
- 6个优秀平面设计网站
- 【python初学者日记】输入年份:判断是否闰年:闰年:yyyy是闰年,这年有366天;yyyy是平年,这年有365天
- Valley Numer hdu-6148
- 【Vue开发实战课后题】子组件为何不可以修改父组件传递的props?
- 线性插值(双线性)(三线性)
- 制作手绘地图并准确覆盖到地图的超简单流程
- 测试开发工作者日记【终焉】:再见~ 小猪
热门文章
- vue导入音乐_vue-music:添加歌曲到队列add-song.vue
- 加权随机采样 (Weighted Random Sampling)
- Neo4j Desktop(Neo4j 桌面)安装插件
- inflate方法的用法
- 什么是重载?重载的作用?
- 【XJTUSE计算机图形学】第三章 几何造型技术(3)——B样条曲线与曲面
- 522还不知道怎么表白吗?——经典设计模式之【观察者模式】
- android程序联网失败,请检查网络是否可用
- js去掉前后空格的函数_Node.js十年,你大爷还是你大爷
- Jmeter进行上传图片接口测试