1、JVM參數配置優化

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

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

Kafka JVM參數可以直接修改啟動腳本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端口監控Kafka Broker信息。可以在bin/kafka-server-start.sh中打開JMX端口變量。

export JMX_PORT=9999

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。