溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
項目使用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服務
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
