線上文檔：https://ke.smartloli.org/
源碼位址：https://github.com/smartloli/kafka-eagle
環境要求：
需要的java版本 java1.8以上版本
下載下傳包Kafka Eagle： kafka-eagle-bin-1.4.8.tar.gz
部署到TDH叢集管理節點中，我放置的目錄為
修改目錄 conf下面的檔案system-config.properties
######################################
# multi zookeeper & kafka cluster list
######################################
kafka.eagle.zk.cluster.alias=cluster1 #定義叢集别名，不要亂改，下面用的這個
cluster1.zk.list=xxxxxx:2181,xxxxxx:2181,xxxxxx:2181 #zk的位址，一般有三個
#cluster2.zk.list=xdn10:2181,xdn11:2181,xdn12:2181
######################################
# broker size online list
######################################
cluster1.kafka.eagle.broker.size=20
######################################
# zk client thread limit
######################################
kafka.zk.limit.size=25
######################################
# kafka eagle webui port
######################################
kafka.eagle.webui.port=8048
######################################
# kafka offset storage
######################################
cluster1.kafka.eagle.offset.storage=zk #這裡用zk，原因是TDH對應5.2.4，下面說原因
######################################
# 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.fix.error=true
######################################
# delete kafka topic token
######################################
kafka.eagle.topic.token=keadmin
######################################
# kafka sasl authenticate
######################################
cluster1.kafka.eagle.sasl.enable=true
cluster1.kafka.eagle.sasl.protocol=SASL_PLAINTEXT
cluster1.kafka.eagle.sasl.mechanism=GSSAPI
cluster1.kafka.eagle.sasl.client=/home/kafka-eagle/kafka-eagle-web-1.4.8/conf/kafka_client_jaas.conf #對應kafka認證用戶端 jaas檔案
######################################
# kafka ssl authenticate
######################################
# 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
######################################
說明：
cluster1.kafka.eagle.offset.storage=zk #這裡用zk，原因是TDH對應5.2.4，下面說原因
給出來的官方文檔說明有兩種方式，第一是存在zk中，第二是存到kafka中
kafka 消費資訊存儲位置，用來相容kafka低版本 0.10以上的版本 一般存儲在kafka中 0.10以下的版本 一般存儲在zk中
下面是作者給出來的說明： 
經過測試星環的TDH5.2.4對應kafka版本為0.10.2，經過測試存儲在了zk裡面 # kafka sasl authenticate
######################################
cluster1.kafka.eagle.sasl.enable=true
cluster1.kafka.eagle.sasl.protocol=SASL_PLAINTEXT
cluster1.kafka.eagle.sasl.mechanism=GSSAPI
cluster1.kafka.eagle.sasl.client=/home/kafka-eagle/kafka-eagle-web-1.4.8/conf/kafka_client_jaas.conf #對應kafka認證用戶端 jaas檔案
在Kafka 0.9.0.0之後，Kafka社群增加了一系列的功能，其中包含對Kafka叢集進行安全管控。支援的權限認證方式如下：
- Broker與Client之間的權限認證（例如Producer和Consumer）。可以使用SSL或SASL，而SASL支援如下方案：
- SASL/GSSAPI（Kerberos），開始于0.9.0.0版本
- SASL/PLAIN，開始于0.10.0.0版本
- SASL/SCRAM-SHA-256和SASL/SCRAM-SHA-512，開始于0.10.2.0版本
- SASL/OAUTHBEARER，開始于2.0版本
2. Broker和Zookeeper之間建立權限認證
3. 在Broker和Client之間、Broker和Broker之間使用SSL建立權限認證時，性能會有所下降，其程度取決于CPU類型和JVM的實作
4. 對Client進行讀寫認證
在實際生産環境中，對于權限認證使用的較多的是SCRAM認證，其原因在《Kafka SCRAM和PLAIN實戰》這篇部落格中詳細解釋。
kafka_client_jaas.conf 檔案内容
kafkaClient {
com.sun.security.auth.module.Krb5LoginModule required
useKeyTab=true
keyTab="/etc/kafka1/conf/kafka.keytab"
storeKey=true
useTicketCache=false
principal="kafka/******@TDH";
};
啟動監控
ke.sh指令使用：
Usage: /home/kafka-eagle/kafka-eagle-web-1.4.8/bin/ke.sh {start|stop|restart|status|stats|find|gc|jdk|version|sdate}
浏覽器通路監控 使用者名admin 密碼123456
BScreen界面，看着高大上
以上就是部署的内容，下次給大家帶來監控項目的具體使用方法
作者：少帥
您的支援是對部落客最大的鼓勵，感謝您的認真閱讀。
本文版權歸作者所有，歡迎轉載，但請保留該聲明。