問(wèn)題

項(xiàng)目使用spring-kafka操作消費(fèi)kafka
近期出現(xiàn)消費(fèi)速度變慢，consumer消費(fèi)一條數(shù)據(jù)平均需要200ms的時(shí)間，并且頻繁發(fā)生，consumer會(huì)停止消費(fèi)十幾秒。

成都創(chuàng)新互聯(lián)公司專(zhuān)注于成都網(wǎng)站建設(shè)、網(wǎng)站設(shè)計(jì)、網(wǎng)頁(yè)設(shè)計(jì)、網(wǎng)站制作、網(wǎng)站開(kāi)發(fā)。公司秉持“客戶(hù)至上,用心服務(wù)”的宗旨,從客戶(hù)的利益和觀點(diǎn)出發(fā),讓客戶(hù)在網(wǎng)絡(luò)營(yíng)銷(xiāo)中找到自己的駐足之地。尊重和關(guān)懷每一位客戶(hù)，用嚴(yán)謹(jǐn)?shù)膽B(tài)度對(duì)待客戶(hù)，用專(zhuān)業(yè)的服務(wù)創(chuàng)造價(jià)值，成為客戶(hù)值得信賴(lài)的朋友，為客戶(hù)解除后顧之憂。

日志分析

以下為日志記錄，consumer會(huì)時(shí)長(zhǎng)從消費(fèi)組中掉出再重新加入

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服務(wù)配置文件server.properties提高系統(tǒng)配置參數(shù)

#Broker處理消息的大線程數(shù)
num.network.threads=cpu核數(shù)加1
#Broker處理磁盤(pán)IO的線程數(shù)
num.io.threads=cpu核數(shù)2倍，大不超過(guò)3倍

備份并重啟kafka服務(wù)

當(dāng)前名稱(chēng)：總結(jié)一次kafka的consumer消費(fèi)能力很低的處理方案-創(chuàng)新互聯(lián)
本文來(lái)源：http://weahome.cn/article/iheeo.html