真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯(lián)網(wǎng)站制作重慶分公司

總結(jié)一次kafka的consumer消費(fèi)能力很低的處理方案

問題

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

成都創(chuàng)新互聯(lián)服務(wù)項(xiàng)目包括文昌網(wǎng)站建設(shè)、文昌網(wǎng)站制作、文昌網(wǎng)頁制作以及文昌網(wǎng)絡(luò)營銷策劃等。多年來,我們專注于互聯(lián)網(wǎng)行業(yè),利用自身積累的技術(shù)優(yōu)勢、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等,向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案,文昌網(wǎng)站推廣取得了明顯的社會效益與經(jīng)濟(jì)效益。目前,我們服務(wù)的客戶以成都為中心已經(jīng)輻射到文昌省份的部分城市,未來相信會繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任!

日志分析

以下為日志記錄,consumer會時長從消費(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處理磁盤IO的線程數(shù)
num.io.threads=cpu核數(shù)2倍,最大不超過3倍

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


網(wǎng)站欄目:總結(jié)一次kafka的consumer消費(fèi)能力很低的處理方案
URL鏈接:http://weahome.cn/article/pgjdjj.html

其他資訊

在線咨詢

微信咨詢

電話咨詢

028-86922220(工作日)

18980820575(7×24)

提交需求

返回頂部