1、JVM參數(shù)配置優(yōu)化

如果使用的CMS GC算法，建議JVM Heap不要太大，在4GB以內(nèi)就可以。JVM太大，導(dǎo)致Major GC或者Full GC產(chǎn)生的“stop the world”時間過長，導(dǎo)致broker和zk之間的session超時，比如重新選舉controller節(jié)點(diǎn)和提升follow replica為leader replica。

JVM也不能過小，否則會導(dǎo)致頻繁地觸發(fā)gc操作，也影響Kafka的吞吐量。另外，需要避免CMS GC過程中的發(fā)生promotion failure和concurrent failure問題。CMSInitiatingOccupancyFraction=70可以預(yù)防concurrent failure問題，提前出發(fā)Major GC。

Kafka JVM參數(shù)可以直接修改啟動腳本bin/kafka-server-start.sh 中的變量值。

export KAFKA_HEAP_OPTS="-Xms6G -Xmx6G -server -XX:+UseG1GC -XX:MaxGCPauseMillis=20 -XX:InitiatingHeapOccupancyPercent=35 -XX:+ExplicitGCInvokesConcurrent -Djava.awt.headless=true"

2、打開JMX端口

主要是為了通過JMX端口監(jiān)控Kafka Broker信息。可以在bin/kafka-server-start.sh中打開JMX端口變量。

export JMX_PORT=9999

總結(jié)

以上是生活随笔為你收集整理的Kafka——JVM调优的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。