1 软件参数
kafka 版本 2.13-2.8.0
zookeeper版本 3.5.8
kafka-eagle 版本 2.0.7
2 zookeeper部署
jdk安装这里就不赘述了，安装ok配置环境变量。
java -version查看版本
安装包：apache-zookeeper-3.5.8-bin.tar.gz
下载链接 Apache Zookeeper
#解压
tar -zxvf apache-zookeeper-3.5.8-bin.tar.gz
#做软链接
ln -s apache-zookeeper-3.5.8-bin.tar.gz zookeeper
#配置环境变量
vi /etc/profile 增加环境变量
export ZK_HOME=/opt/apps/zookeeper
export PATH=$PATH:$ZK_HOME/bin
#生效
source /etc/profile
启动zookeeper
zkServer.sh start 启动
zkServer.sh status 查看状态
2 kafka部署
安装包：kafka_2.13-2.8.0.tgz
下载链接：Apache Kafka
#解压
tar -zxvf kafka_2.13-2.8.0.tgz
#做软链接
ln -s kafka_2.13-2.8.0.tgz kafka
# 修改配置文件
vi kafka/config/server.properties
#赋予权限，写主机ip地址，这个很重要，不然kakfa外网访问不了。
listeners=PLAINTEXT://10.240.52.8:9092
#zk的地址
zookeeper.connect=10.240.52.8:2181
#日志地址
# 修改启动脚本
vi kafka/bin/kafka-server-start.sh
#添加参数，为kafka-eagle 提供jxm数据支持，放置在脚本前面，如图。
if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-server -Xms2G -Xmx2G -XX:PermSize=128m -XX:+UseG1GC -XX:MaxGCPauseMillis=200 -XX:ParallelGCThreads=8 -XX:ConcGCThreads=5 -XX:InitiatingHeapOccupancyPercent=70"
export JMX_PORT="9999"
fi
配置参考
kafka启动
进入到kafka目录
后台启动
./bin/kafka-server-start.sh config/server.properties &
3 kafka-eagle部署
kafka-eagle现在更名为 EFAK
kafka-eagle-bin-2.0.7.tar.gz
- 源码： https://github.com/smartloli/kafka-eagle/
- 官网：https://www.kafka-eagle.org/
- 下载： http://download.kafka-eagle.org/
- 安装文档： https://docs.kafka-eagle.org/2.env-and-install
解压缩包重命名目录
mkdir /opt/software
tar xf kafka-eagle-bin-2.0.7.tar.gz -C /opt/software/
cd /opt/software/kafka-eagle-bin-2.0.7
tar xf kafka-eagle-web-2.0.7-bin.tar.gz
mv kafka-eagle-web-2.0.7 kafka-eagle
配置环境变量
vim /etc/profile
export KE_HOME= /opt/software/kafka-eagle
PATH=$PATH:$KE_HOME/bin
# 更新环境变量
source /etc/profile
修改Kafka-Eagle配置文件
cd kafka-eagle/conf
vim system-config.properties
######################################
# multi zookeeper&kafka cluster list
# zookeeper和kafka集群配置
######################################
kafka.eagle.zk.cluster.alias=cluster1
cluster1.zk.list=10.0.0.200:2181,10.0.0.200:2182,10.0.0.200:2183
######################################
# kafka eagle webui port
# web页面访问端口号
######################################
kafka.eagle.webui.port=8048
######################################
# kafka jdbc driver address
# kafka默认使用sqlite数据库，Centos自带，注意配置下数据库存放路径就行
######################################
kafka.eagle.driver=org.sqlite.JDBC
#修改到对应路径下面，不然启动回报错
kafka.eagle.url=jdbc:sqlite:/opt/software/kafka-eagle/db/ke.db
kafka.eagle.username=root
kafka.eagle.password=www.kafka-eagle.org
启动kafka-eagle
cd ../bin/
chmod +x ke.sh
./ke.sh start
# 网址密码
* Kafka Eagle Service has started success.
* Welcome, Now you can visit 'http://10.0.0.200:8048/ke'
* Account:admin ,Password:123456
启动截图：
启动截图
参数监控，kakfa启动脚本配置才有。
jxm参数显示
