Kafka Eagle 安装与使用

约定不等于承诺〃 2023-01-14 09:00 201阅读 0赞

# Kafka Eagle 安装与使用 #

## 1. eagle 下载地址 ##

官网：[https://www.kafka-eagle.org/][https_www.kafka-eagle.org]

GitHub: [https://github.com/smartloli/kafka-eagle][https_github.com_smartloli_kafka-eagle]

下载地址: [kafka-eagle-bin-2.0.4.tar.gz][]

官网安装指引：[Kafka Install on Linux/macOS][Kafka Install on Linux_macOS]

硬件要求：

内存：2G

CPU：> 1 核

## 2. 安装JDK ##

### 2.1 这个不是重点，解压设置环境变量即可 ###

cd /usr/java
    tar -zxvf jdk-xxxx.tar.gz
    mv jdk-xxxx jdk1.8
    vi /etc/profile
    export JAVA_HOME=/usr/java/jdk1.8
    export PATH=$PATH:$JAVA_HOME/bin

### 2.2 kafka 开发jmx端口 ###

修改kafka启动脚本，添加jmx 端口

vim /opt/kafka/bin/kafka-server-start.sh

修改如下：

# 28行
    if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
        export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
        # 开启jmx端口
        export JMX_PORT="9999"
    fi

## 3. 解压 Kafka Eagle ##

cd /opt
    tar -xzvf kafka-eagle-2.0.4-bin.tar.gz
    
    # 重命名
    mv kafka-eagle-2.0.4 kafka-eagle

## 4. 配置环境变量 ##

vi /etc/profile
    export KE_HOME=/opt/kafka-eagle
    export PATH=$PATH:$KE_HOME/bin
    
    # 立即生效
    source /etc/profile

使用 source /etc/profile 使设置立即生效

## 5. 配置Kafka Eagle 系统文件 ##

kafka eagle 支持同时监控多个kafka 集群，这里只监控一个修改配置如下：

cd /opt/kafka-eagle
    cp system-config.properties sysconfig.properties.backup
    vim system-config.properties

# 1. 集群修改
    ######################################
    # multi zookeeper & kafka cluster list
    ######################################
    kafka.eagle.zk.cluster.alias=cluster1
    cluster1.zk.list=centos7-01:2181,centos7-02:2181,centos7-03:2181
    
    # 2. offset 存储位置修改
    ######################################
    # kafka offset storage
    ######################################
    cluster1.kafka.eagle.offset.storage=kafka
    # cluster2.kafka.eagle.offset.storage=zk
    
    # 3. 修改数据库目录，目录需要自己创建
    ######################################
    # kafka sqlite jdbc driver address
    ######################################
    kafka.eagle.driver=org.sqlite.JDBC
    kafka.eagle.url=jdbc:sqlite:/opt/kafka-eagle/db/ke.db
    kafka.eagle.username=root
    kafka.eagle.password=www.kafka-eagle.org

## 6. 启动 kafka-eagle ##

1.  给脚本添加执行权限
    
        cd /opt/kafka-eagle/bin
        chmod +x ke.sh 
        ./ke.sh start
    
    启动结果如下：
    
    ![image-20210420125925015][]
    
    如果报错，可以在 /opt/kafka-eagle/logs 目录下查看到详细的错误信息
2.  通过浏览器访问：http://192.168.56.11:8048
3.  关闭重启
    
        ke.sh restart
        ke.sh stopjps
        
        # 查看状态
        ke.sh status
    
    ## 7. 简单使用 ##
    
    ![image-20210420131624766][]
    
    ![image-20210420133345280][]

![image-20210420134758416][]

[https_www.kafka-eagle.org]: https://www.kafka-eagle.org/
[https_github.com_smartloli_kafka-eagle]: https://github.com/smartloli/kafka-eagle
[kafka-eagle-bin-2.0.4.tar.gz]: https://codeload.github.com/smartloli/kafka-eagle-bin/tar.gz/v2.0.4
[Kafka Install on Linux_macOS]: https://www.kafka-eagle.org/articles/docs/installation/linux-macos.html
[image-20210420125925015]: /images/20221022/883b9d7e72644accb34d30d2edb68b96.png
[image-20210420131624766]: /images/20221022/e890db3c8d9348d8935708aa05c88a89.png
[image-20210420133345280]: /images/20221022/bb4c103d632b4823b1af046169529bb9.png
[image-20210420134758416]: /images/20221022/8ef359eff87f491bb22fd83313475059.png