kafka-eagle配置指南

基本配置按照官方文档来就可以:Docshttp://www.kafka-eagle.org/articles/docs/installation/linux-macos.html

以下列出一些特别需要注意的地方,方便大家少走弯路。 

JAVA_HOME

 必须配置这个环境变量。即便当前操作系统不配置JAVA_HOME也能正常使用Java时,也需要特别配置一下这个环境变量。

KE_HOME

必须配置这个环境变量。执行ke.sh start时会检查这些环境变量。

Note: Kafka version is "-" or JMX Port is "-1" maybe kafka broker jmxport disable.

需要配置kafka 的jmx 端口。如果不配置,eagle不能检测broker的内存和版本情况。

# 需要制定JMX PORT,此处给出一种配置方式
# 修改kafka-server-start.sh中KAFKA_HEAP_OPTS下的配置,添加一行:export JMX_PORT="9999"
if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
    #export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
    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"
fi


Note: Zookeeper version is "3.5+" or version is "-" maybe zookeeper client command disable.

如果使用的zookeeper版本太高,eagle会检测不到zookeeper的状态,需要一下修改。

高版本Zookeeper需要修改zookeeper客户端命令行相关的配置。官方文档:Docshttp://www.kafka-eagle.org/articles/docs/quickstart/metrics.html

文档里说:

When your zookeeper version is after 3.5, you need to open zkcli permission to repair the script content

vi zkServer.sh
...
// after 77 lines
ZOOMAIN="-Dzookeeper.4lw.commands.whitelist=* ${ZOOMAIN}"

 大家注意,如果用的是zookeeper3.6.0版本,那确实在77行后面加一行就可以了。

大家注意,如果用的是zookeeper3.7.1,或其他高版本,有时候并不是在第77行后加入这一行,需要以下变通:

# 以zookeeper 3.7.1为例:
# 在此项配置【if [ "x$SERVER_JVMFLAGS" != "x" ]】前面,加入如下配置:
ZOOMAIN="-Dzookeeper.4lw.commands.whitelist=* ${ZOOMAIN}"


版权声明:本文为haohaizijhz原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。