問題

項目使用spring-kafka操作消費kafka
近期出現消費速度變慢，consumer消費一條數據平均需要200ms的時間，并且頻繁發生，consumer會停止消費十幾秒。

成都創新互聯服務項目包括文昌網站建設、文昌網站制作、文昌網頁制作以及文昌網絡營銷策劃等。多年來，我們專注于互聯網行業，利用自身積累的技術優勢、行業經驗、深度合作伙伴關系等，向廣大中小型企業、政府機構等提供互聯網行業的解決方案，文昌網站推廣取得了明顯的社會效益與經濟效益。目前，我們服務的客戶以成都為中心已經輻射到文昌省份的部分城市，未來相信會繼續擴大服務區域并繼續獲得客戶的支持與信任！

日志分析

以下為日志記錄，consumer會時長從消費組中掉出再重新加入

o.a.k.c.c.i.AbstractCoordinator:542 - Marking the coordinator 127.0.0.1:9092 (id: 2147483643 rack: null) dead for group group.id 
o.a.k.c.c.i.AbstractCoordinator:505 - Discovered coordinator 127.0.0.1:9092 (id: 2147483643 rack: null) for group group.id. 
o.a.k.c.c.i.ConsumerCoordinator:292 - Revoking previously assigned partitions [topic-12] for group group.id 
o.a.k.c.c.i.AbstractCoordinator:326 - (Re-)joining group group.id 
o.a.k.c.c.i.AbstractCoordinator$SyncGroupResponseHandler:434 - Successfully joined group group.id with generation 12182 
o.a.k.c.c.i.ConsumerCoordinator:231 - Setting newly assigned partitions [topic-12] for group group.id 

解決方案

kafka服務配置文件server.properties提高系統配置參數

#Broker處理消息的最大線程數
num.network.threads=cpu核數加1
#Broker處理磁盤IO的線程數
num.io.threads=cpu核數2倍，最大不超過3倍

備份并重啟kafka服務