失眠网,内容丰富有趣,生活中的好帮手!
失眠网 > Kafka监控系统Kafka Eagle:支持kerberos认证

Kafka监控系统Kafka Eagle:支持kerberos认证

时间:2024-06-23 15:25:06

相关推荐

Kafka监控系统Kafka Eagle:支持kerberos认证

在线文档:/

作者博客:/smartloli/p/9371904.html

源码地址:/smartloli/kafka-eagle

源码编译:直接提供的脚本./build.sh或者直接执行脚本里面的命令mvnclean&&mvnpackage -DskipTests

编译结果:kafka-eagle\kafka-eagle-web\target\kafka-eagle-web-1.2.8-bin.tar.gz

安装jdk,配置JAVA_HOME、KE_HOME(即kafka-eagle路径)。

配置system-config.properties

####################################### multi zookeeper&kafka cluster list######################################kafka.eagle.zk.cluster.alias=cluster1#,cluster2cluster1.zk.list=tdn1:2181,tdn2:2181,tdn3:2181#cluster2.zk.list=xdn10:2181,xdn11:2181,xdn12:2181####################################### 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=kafka#cluster2.kafka.eagle.offset.storage=zk####################################### enable kafka metrics######################################kafka.eagle.metrics.charts=truekafka.eagle.sql.fix.error=true####################################### kafka sql topic records max######################################kafka.eagle.sql.topic.records.max=5000####################################### alarm email configure######################################kafka.eagle.mail.enable=falsekafka.eagle.mail.sa=alert_sakafka.eagle.mail.username=alert_sa@kafka.eagle.mail.password=mqslimczkdqabbbhkafka.eagle.mail.server.host=kafka.eagle.mail.server.port=25####################################### alarm im configure#######################################kafka.eagle.im.dingding.enable=true#kafka.eagle.im.dingding.url=/robot/send?access_token=#kafka.eagle.im.wechat.enable=true#kafka.eagle.im.wechat.url=https://qyapi./cgi-bin/message/send?access_token=#kafka.eagle.im.wechat.touser=#kafka.eagle.im.wechat.toparty=#kafka.eagle.im.wechat.totag=#kafka.eagle.im.wechat.agentid=####################################### delete kafka topic token######################################kafka.eagle.topic.token=keadmin####################################### kafka sasl authenticate######################################kafka.eagle.sasl.enable=truekafka.eagle.sasl.protocol=SASL_PLAINTEXTkafka.eagle.sasl.mechanism=GSSAPI####################################### kafka jdbc driver address######################################kafka.eagle.driver=org.sqlite.JDBCkafka.eagle.url=jdbc:sqlite:/kafka-eagle/db/ke.dbkafka.eagle.username=rootkafka.eagle.password=root

配置kafka_client_jaas.conf

KafkaClient {com.sun.security.auth.module.Krb5LoginModule requireduseKeyTab=truestoreKey=truekeyTab="/etc/security/keytabs/kafka_client.keytab"principal="kafka-client-1@";};

或者(确保本地有票据缓存 klist -l可查看)

KafkaClient {com.sun.security.auth.module.Krb5LoginModule requireduseTicketCache=truerenewTicket=trueserviceName="kafka";};

Kafka系统默认是没有开启JMX端口的,所以Kafka Eagle的监控趋势图默认采用不启用的方式,即kafka.eagle.metrics.charts=false。如果需要查看监控趋势图,需要开启Kafka系统的JMX端口,设置该端口在$KAFKA_HOME/bin/kafka-server-start.sh脚本中,设置内容如下:

vi kafka-server-start.shif [ "x$KAFKA_HEAP_OPTS" = "x" ]; thenexport 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

需要注意的时,这里的端口不一定非要设置成9999,端口只有可用,均可。Kafka Eagle系统会自动获取这个JMX端口,采集结果如下:

创建数据库

sqlite3 /kafka-eagle/db/ke.db

/sqlite/sqlite-create-database.html

chmod +x ke.sh

./ke.sh start

如果觉得《Kafka监控系统Kafka Eagle:支持kerberos认证》对你有帮助,请点赞、收藏,并留下你的观点哦!

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。