当前位置: 首页 > news >正文

kafka docker 安装

先启动起 zookeeper

(1)服务: 192.168.190.35

docker run -d --name kafka1 \

-p 9092:9092 \

-e KAFKA_BROKER_ID=0 \

-e delete.topic.enable=true \

-e num.partitions=1 \

-e KAFKA_ZOOKEEPER_CONNECT=192.168.192.35:2181 \

-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.190.35:9092 \

-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \

-t wurstmeister/kafka \

(2)服务: 192.168.190.36

docker run -d --name kafka1 \

-p 9092:9092 \

-e KAFKA_BROKER_ID=1 \

-e delete.topic.enable=true \

-e num.partitions=1 \

-e KAFKA_ZOOKEEPER_CONNECT=192.168.192.36:2181 \

-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.190.36:9092 \

-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \

-t wurstmeister/kafka \

(3)efak 工具安装

3.1下载地址:https://www.kafka-eagle.org/
3.2 jdk 尽量不用yum安装(遇到坑),下载正式 jdk 解压缩到:

/usr/local/jdk1.8.0_351

/etc/profile 增加 export JAVA_HOME=/usr/local/jdk1.8.0_351

export KE_HOME=/usr/local/kafaka_efak

完事加载下: source /ect/profile

3.3 编辑配置文件 ./conf/system-config.properties

######################################

# multi zookeeper & kafka cluster list

# Settings prefixed with 'kafka.eagle.' will be deprecated, use 'efak.' instead

######################################

efak.zk.cluster.alias=cluster1 #这里就剩 cluster1

#cluster1.zk.list=tdn1:2181,tdn2:2181,tdn3:2181 #这行备注掉

#cluster2.zk.list=xdn10:2181,xdn11:2181,xdn12:2181 #这里备注掉

cluster1.zk.list=192.168.192.35:2181,192.168.192.36:2181 #这里写zookeeper地址接口

######################################

......

######################################

# kafka sqlite jdbc driver address

######################################

#efak.driver=org.sqlite.JDBC

#efak.url=jdbc:sqlite:/hadoop/kafka-eagle/db/ke.db

#efak.username=root

#efak.password=www.kafka-eagle.org

######################################

# kafka mysql jdbc driver address 开启mysql

######################################

efak.driver=com.mysql.cj.jdbc.Driver

efak.url=jdbc:mysql://127.0.0.1:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull

efak.username=root

efak.password=123456

3.4 编辑启动文件 ./bin/ke.sh

export JAVA_HOME=/usr/local/jdk1.8.0_351 #新增这一行 这里jdk地址,要原生jkd。不要yum

export MALLOC_ARENA_MAX=1

(4)启动 ./ke.sh start

[2023-03-14 22:36:06] INFO: [Job done!]

Welcome to

______ ______ ___ __ __

/ ____/ / ____/ / | / //_/

/ __/ / /_ / /| | / ,<

/ /___ / __/ / ___ | / /| |

/_____/ /_/ /_/ |_|/_/ |_|

( Eagle For Apache Kafka® )

Version v3.0.1 -- Copyright 2016-2022

*******************************************************************

* EFAK Service has started success.

* Welcome, Now you can visit 'http://127.0.0.1:8048'

(5)登录 http://192.168.192.35:8048/

amdin 123456

http://www.lryc.cn/news/39591.html

相关文章:

  • SpringBean管理
  • 关于Vue3中reactive的意义
  • 平衡三进制
  • python爬取网站数据
  • CSS的三大特性
  • Linux-scheduler之负载均衡(二)
  • VScode第三方插件打开sqlite数据库
  • Kafka 监控
  • MultipartFile与File的互转
  • 数据结构与算法基础-学习-15-二叉树
  • 接口测试要测试什么?
  • 2023.03.12学习总结
  • 数据结构入门6-1(图)
  • 把C#代码上传到NuGet,大佬竟是我自己!!!
  • 解决前端“\n”不换行问题
  • Python打包成exe,文件太大问题解决办法(比保姆级还保姆级)
  • CSS弹性布局flex属性整理
  • 14个你需要知道的实用CSS技巧
  • 【Flutter从入门到入坑之四】构建Flutter界面的基石——Widget
  • 中职网络空间安全windows渗透
  • 普通二叉树的操作
  • Oracle:递归树形结构查询功能
  • MongoDB数据库性能监控详解
  • python不要再使用while死循环,使用定时器代替效果更佳!
  • 什么是接口测试?十年阿里测试人教你怎样做接口测试
  • 1.10-1.12 Makefile
  • Leetcode. 88合并两个有序数组
  • 【数据库】数据库查询(进阶命令详解)
  • 参数缺省和函数重载讲解
  • 关于召开2023第八届国际发酵培养基应用发展技术论坛的通知