栏目分类:
子分类:
返回
文库吧用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
文库吧 > IT > 软件开发 > 后端开发 > Java

docker install kafka

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

docker install kafka

1. 环境使用
docker run -d --name zookeeperau 
-p 2181:2181 
-v /docker/volumes/zookeeper/data:/data 
-v /docker/volumes/zookeeper/datalog:/datalog 
-v /docker/volumes/zookeeper/logs:/logs 
-v /etc/localtime:/etc/localtime 
wurstmeister/zookeeper:latest

参数说明#
-p 26313:2181 zk的2181端口映射为26313端口
-v /etc/localtime:/etc/localtime 容器时间同步主机时间 , 其他-v为把 /data /datalog /logs 映射到主机对应的目录

2. 安装kafka
docker run -d --restart=always  --name kafkaau 
-p 9092:9092 
-e KAFKA_BROKER_ID=0 
-e KAFKA_ZOOKEEPER_CONNECT=192.168.2.103:2181 
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.2.103:9092 
-v /etc/localtime:/etc/localtime 
bitnami/kafka:2.6.0

参数说明#
-p 21661:9092 kafka的 9092 端口映射为 21661 端口
-e KAFKA_BROKER_ID=0 在kafka集群中,每个kafka用BROKER_ID来区分自己 , 如需配置kafka集群可 修改此id 和 上述 21661 端口号映射即可部署集群
-e KAFKA_ZOOKEEPER_CONNECT=192.168.100.21:26313 配置zookeeper连接地址
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.100.21:21661 把kafka的地址注册给zookeeper,如果是远程访问要改成外网IP,否则可能出现无法连接
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 配置kafka的监听端口
-v /etc/localtime:/etc/localtime 容器时间同步虚拟机的时间

3. Topic CRUD

READ

bin/kafka-topics.sh --list --zookeeper [ZKHOST]:2181

READ INFO

CREATE

bin/kafka-topics.sh --create --zookeeper [ZKHOST]:2181 [TNAME] --partitions [INT] --replication-factor [INT]

bin/kafka-topics.sh --create --zookeeper hadoop103:2181 [TNAME] --partitions 2 --replication-factor 0

UPDATe x

DELETE

4. 消息发送 / 消费 测试# 4.1 进入kafka容器#
$ docker exec -it kafka bash
4.2 进入 bin 目录#
$ cd /opt/kafka/bin
4.3 发送消息#
> ./kafka-console-producer.sh --broker-list localhost:9092 --topic test_topic
4.4 消费消息#
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test_topic --from-beginning
daemon 自退问题

#使用镜像 centos:latest 以后台模式启动一个容器 docker run -d centos

问题:然后 docker ps -a 进行查看, 会发现容器已经退出

很重要的要说明的一点: Docker容器后台运行,就必须有一个前台进程.容器运行的命令如果不是那些一直挂起的命令(比如运行top,tail),就是会自动退出的。 这个是docker的机制问题,

比如你的 web 容器,我们以 nginx 为例,正常情况下,我们配置启动服务只需要启动响应的 service 即可。例如 service nginx start 但是,这样做, nginx 为后台进程模式运行,就导致 docker 前台没有运行的应用,这样的容器后台启动后,会立即自杀因为他觉得他没事可做了.

所以,最佳的解决方案是,将你要运行的程序以前台进程的形式运行,常见就是命令行模式,表示我还有交互操作,别中断,O(∩_∩)O哈哈~

转载请注明:文章转载自 www.wk8.com.cn
本文地址:https://www.wk8.com.cn/it/1040109.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 wk8.com.cn

ICP备案号:晋ICP备2021003244-6号