kakfa監控之kafka eagle
阿新 • • 發佈:2021-12-15
一.修改kafka啟動命令
修改kafka-server-start.sh命令中
if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
fi
為:
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" #export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G" fi 修改後分發檔案到其他kafka節點
二.上傳eagle安裝包到伺服器並解壓
- 在安裝包所在路徑執行解壓命令:
安裝包需要解壓兩層
將第一次解壓得到的kafka-eagle-web-1.3.7-bin.tar.gz解壓安裝:
tar -zxvf kafka-eagle-web-1.3.7-bin.tar.gz -C /opt/module/
- 修改配置檔案
###################################### # multi zookeeper&kafka cluster list ###################################### kafka.eagle.zk.cluster.alias=cluster1 cluster1.zk.list=hadoop101:2181,hadoop102:2181,hadoop103:2181 ###################################### # kafka offset storage ###################################### cluster1.kafka.eagle.offset.storage=kafka ###################################### # enable kafka metrics ###################################### kafka.eagle.metrics.charts=true kafka.eagle.sql.fix.error=false ###################################### # kafka jdbc driver address ###################################### kafka.eagle.driver=com.mysql.jdbc.Driver kafka.eagle.url=jdbc:mysql://hadoop101:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull kafka.eagle.username=root kafka.eagle.password=yourpassword
三,啟動kafka和eagle
bin/ke.sh start
瀏覽器訪問 : http://hadoop101:8048
輸入提示的賬號密碼登入
可以檢視到叢集資訊