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