1、下载安装包
2、上传解压
tar -xf kafka-eagle-bin-2.0.6.tar.gz tar -xf kafka-eagle-web-2.0.6-bin.tar.gz
3、修改kafka-eagle-bin-2.0.6/kafka-eagle-web-2.0.6/conf下的system-config.properties （直接复制，然后把标红的地方修改即可，mysql的库要自己创建）
###################################### # multi zookeeper & kafka cluster list ###################################### kafka.eagle.zk.cluster.alias=cluster1 cluster1.zk.list=hadoop101:2181,hadoop102:2181,hadoop103:2181 #cluster2.zk.list=xdn10:2181,xdn11:2181,xdn12:2181 ###################################### # zookeeper enable acl ###################################### #cluster1.zk.acl.enable=false #cluster1.zk.acl.schema=digest #cluster1.zk.acl.username=test #cluster1.zk.acl.password=test123 ###################################### # broker size online list ###################################### cluster1.kafka.eagle.broker.size=20 ###################################### # zk client thread limit ###################################### kafka.zk.limit.size=32 ###################################### # kafka eagle webui port ###################################### kafka.eagle.webui.port=8048 ###################################### # kafka jmx acl and ssl authenticate ###################################### #cluster1.kafka.eagle.jmx.acl=false #cluster1.kafka.eagle.jmx.user=keadmin #cluster1.kafka.eagle.jmx.password=keadmin123 #cluster1.kafka.eagle.jmx.ssl=false #cluster1.kafka.eagle.jmx.truststore.location=/Users/dengjie/workspace/ssl/certificates/kafka.truststore #cluster1.kafka.eagle.jmx.truststore.password=ke123456 ###################################### # kafka offset storage ###################################### cluster1.kafka.eagle.offset.storage=kafka #cluster2.kafka.eagle.offset.storage=zk ###################################### # kafka jmx uri ###################################### cluster1.kafka.eagle.jmx.uri=service:jmx:rmi:///jndi/rmi://%s/jmxrmi ###################################### # kafka metrics, 15 days by default ###################################### kafka.eagle.metrics.charts=true kafka.eagle.metrics.retain=15 ###################################### # kafka sql topic records max ###################################### kafka.eagle.sql.topic.records.max=5000 kafka.eagle.sql.topic.preview.records.max=10 ###################################### # delete kafka topic token ###################################### kafka.eagle.topic.token=keadmin ###################################### # kafka sasl authenticate ###################################### #cluster1.kafka.eagle.sasl.enable=false #cluster1.kafka.eagle.sasl.protocol=SASL_PLAINTEXT #cluster1.kafka.eagle.sasl.mechanism=SCRAM-SHA-256 #cluster1.kafka.eagle.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="kafka" password="kafka-eagle"; #cluster1.kafka.eagle.sasl.client.id= #cluster1.kafka.eagle.blacklist.topics= #cluster1.kafka.eagle.sasl.cgroup.enable=false #cluster1.kafka.eagle.sasl.cgroup.topics= #cluster2.kafka.eagle.sasl.enable=false #cluster2.kafka.eagle.sasl.protocol=SASL_PLAINTEXT #cluster2.kafka.eagle.sasl.mechanism=PLAIN #cluster2.kafka.eagle.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="kafka" password="kafka-eagle"; #cluster2.kafka.eagle.sasl.client.id= #cluster2.kafka.eagle.blacklist.topics= #cluster2.kafka.eagle.sasl.cgroup.enable=false #cluster2.kafka.eagle.sasl.cgroup.topics= ###################################### # kafka ssl authenticate ###################################### #cluster3.kafka.eagle.ssl.enable=false #cluster3.kafka.eagle.ssl.protocol=SSL #cluster3.kafka.eagle.ssl.truststore.location= #cluster3.kafka.eagle.ssl.truststore.password= #cluster3.kafka.eagle.ssl.keystore.location= #cluster3.kafka.eagle.ssl.keystore.password= #cluster3.kafka.eagle.ssl.key.password= #cluster3.kafka.eagle.ssl.endpoint.identification.algorithm=https #cluster3.kafka.eagle.blacklist.topics= #cluster3.kafka.eagle.ssl.cgroup.enable=false #cluster3.kafka.eagle.ssl.cgroup.topics= ###################################### # kafka sqlite jdbc driver address ###################################### #kafka.eagle.driver=org.sqlite.JDBC #kafka.eagle.url=jdbc:sqlite:/hadoop/kafka-eagle/db/ke.db #kafka.eagle.username=root #kafka.eagle.password=www.kafka-eagle.org ###################################### # kafka mysql jdbc driver address ###################################### kafka.eagle.driver=com.mysql.cj.jdbc.Driver kafka.eagle.url=jdbc:mysql://127.0.0.1:3306/ke1?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull kafka.eagle.username=root kafka.eagle.password=yang156122
4、进入kafka-eagle-bin-2.0.6/kafka-eagle-web-2.0.6/bin，启动程序
ke.sh start 启动
ke.sh stop 停止
FAQ
1、kafka-eagle会使用kafka9988端口，如果没有启动，不会有数据，启动kafka的时候请加 JMX_PORT=9988
JMX_PORT=9988 /usr/java/kafka2.3/kafka_2.11-2.3.0/bin/kafka-server-start.sh -daemon /usr/java/kafka2.3/kafka_2.11-2.3.0/config/server.properties
2、zookeeper版本信息没有显示：请在zoo.cfg文件中添加
4lw.commands.whitelist=*