班服定制网站,wordpress开玩笑 呵,什么是网络营销的任务,做衣服上哪些网站文章目录一、安装、配置、验证1. 安装包下载2. 开启kafka JMX3. 安装JDK#xff0c;配置JAVA_HOME4. 上传安装包、解压5. 配置Kafka-eagle环境变量6. 配置Kafka_eagle7. 配置ke.sh8. 启动Kafka_eagle9. 防火墙10. 访问Kafka eagle二、监控面本总览2.1. Dashboard2.2. MESSAGE2… 文章目录一、安装、配置、验证1. 安装包下载2. 开启kafka JMX3. 安装JDK配置JAVA_HOME4. 上传安装包、解压5. 配置Kafka-eagle环境变量6. 配置Kafka_eagle7. 配置ke.sh8. 启动Kafka_eagle9. 防火墙10. 访问Kafka eagle二、监控面本总览2.1. Dashboard2.2. MESSAGE2.3. Application2.4. Performance2.5. SYSTEM一、安装、配置、验证
1. 安装包下载
官网地址EFAK 本文使用3.0.1版本
2. 开启kafka JMX
在启动Kafka的脚本前打开JMX端口本文将其写在一键启动中将以下代码写在自定义的kafka-start.sh中即可实现一键启动这里还涉及一个文件slave中已经写明了各个主机名称这里一键启动不做多余赘述。
cat /export/onekey/slave | while read line
do
{echo $line ssh $line source /etc/profile;export JMX_PORT9988;nohup ${KAFKA_HOME}/bin/kafka-server-start.sh ${KAFKA_HOME}/config/server.properties /dev/nul* 21 }
wait
done3. 安装JDK配置JAVA_HOME
本机已安装好环境
4. 上传安装包、解压
cd /app
wget https://archive.fastgit.org/smartloli/kafka-eagle-bin/archive/v3.0.1.tar.gz将其解压到 /app 文件夹下
tar -zxvf kafka-eagle-bin-3.0.1.tar.gz
cd kafka-eagle-bin-3.0.1/
tar -zxvf efak-web-3.0.1-bin.tar.gz 5. 配置Kafka-eagle环境变量
vim /etc/profileexport KE_HOME/app/kafka-eagle-bin-3.0.1/efak-web-3.0.1
export PATH$PATH:$KE_HOME/binsource /etc/profile6. 配置Kafka_eagle
使用vi打开conf目录下的system-config.properties
cd /app/kafka-eagle-bin-3.0.1/efak-web-3.0.1
vim conf/system-config.properties第一处改动第五行附近之前版本都是kafka.eagle 现在默认称为efak名称改了另外把cluster2注释
efak.zk.cluster.aliascluster16 cluster1.zk.list192.168.105.125:2181,192.168.105.129:2181,192.168.105.130:21817 #cluster2.zk.listxdn10:2181,xdn11:2181,xdn12:2181第二处改动54行注释
53 cluster1.efak.offset.storagekafka
54 #cluster2.efak.offset.storagezk第三处81-111行全部注销
######################################79 # kafka sasl authenticate80 ######################################81 #cluster1.efak.sasl.enablefalse82 #cluster1.efak.sasl.protocolSASL_PLAINTEXT83 #cluster1.efak.sasl.mechanismSCRAM-SHA-25684 #cluster1.efak.sasl.jaas.configorg.apache.kafka.common.security.scram.ScramLoginModule required usernamekafka passwordkafka-eagle;85 #cluster1.efak.sasl.client.id86 #cluster1.efak.blacklist.topics87 #cluster1.efak.sasl.cgroup.enablefalse88 #cluster1.efak.sasl.cgroup.topics89 #cluster2.efak.sasl.enablefalse90 #cluster2.efak.sasl.protocolSASL_PLAINTEXT91 #cluster2.efak.sasl.mechanismPLAIN92 #cluster2.efak.sasl.jaas.configorg.apache.kafka.common.security.plain.PlainLoginModule required usernamekafka passwordkafka-eagle;93 #cluster2.efak.sasl.client.id94 #cluster2.efak.blacklist.topics95 #cluster2.efak.sasl.cgroup.enablefalse96 #cluster2.efak.sasl.cgroup.topics97 98 ######################################99 # kafka ssl authenticate
100 ######################################
101 #cluster3.efak.ssl.enablefalse
102 #cluster3.efak.ssl.protocolSSL
103 #cluster3.efak.ssl.truststore.location
104 #cluster3.efak.ssl.truststore.password
105 #cluster3.efak.ssl.keystore.location
106 #cluster3.efak.ssl.keystore.password
107 #cluster3.efak.ssl.key.password
108 #cluster3.efak.ssl.endpoint.identification.algorithmhttps
109 #cluster3.efak.blacklist.topics
110 #cluster3.efak.ssl.cgroup.enablefalse
111 #cluster3.efak.ssl.cgroup.topics第四处125行
24 efak.drivercom.mysql.jdbc.Driver
125 efak.urljdbc:mysql://192.168.105.122:3306/ke?useUnicodetruecharacterEncodingUTF-8zeroDateTimeBehaviorconvertToNull
126 efak.usernameroot
127 efak.password123456说明这里node1上的MySQL用户名和密码要正确123456是文件给的默认值记得改不然无法登录Kafka_eagle 创建ke数据库
7. 配置ke.sh
cd /app/kafka-eagle-bin-3.0.1/efak-web-3.0.1/bin
vim ke.sh在25行添加JAVA_HOME
export JAVA_HOME/app/jdk1.8.0_301添加执行脚本的权限
chmod ux ke.sh8. 启动Kafka_eagle
./ke.sh start9. 防火墙
开放端口开放后需要要重启防火墙才生效 、重新启动防火墙
firewall-cmd --zonepublic --add-port8048/tcp --permanent
firewall-cmd --reload10. 访问Kafka eagle
访问之前查看kafka和zookeeper是否启动Kafka未启动不能访问
默认用户admin 密码为123456
#访问地址
http://node1:8048
或
http://ip地址:8048 二、监控面本总览
2.1. Dashboard
Overview
管控台面板
名称节点数kafka3zookeeper3topic1consumer2TV Dashboard 大屏监控面板
2.2. MESSAGE
MESSAGE-- Topics 主题相关-- Create 创建-- List 列表查看-- KSQL-- Mock-- Metadata-- BalanceCreate List 主题列表 点击具体某一个主题查看主题详情元数据 KSQL Mock 模拟发送消息测试 Metadata Balance
2.3. Application
Application-- Consumers-- Groups2.4. Performance
Performance-- Node-- KAFKA-- ZOOKEEPER-- efakserver-- managementKAFKA kafka集群 ZOOKEEPER zookeeper集群 efakserver management
2.5. SYSTEM
