建網(wǎng)站一般最低多少錢什么是網(wǎng)絡(luò)推廣營銷
目錄
- 一、場景
- 1.1、場景應(yīng)用環(huán)境
- 1.2、 問題重現(xiàn)
- 二、問題分析
- 三、解決方案
一、場景
1.1、場景應(yīng)用環(huán)境
- 卡夫卡:2.11-1.0.1。
- 主題:并發(fā)度為 5 且分區(qū)為 5 。
1.2、 問題重現(xiàn)
-
當(dāng)應(yīng)用程序重新啟動并且在分區(qū)分配之前在主題上發(fā)布消息時,主題的 5 個消費(fèi)者找到組協(xié)調(diào)器并向組協(xié)調(diào)器發(fā)送加入組請求。預(yù)計會得到團(tuán)體協(xié)調(diào)員的答復(fù),但沒有收到任何答復(fù),并且在Kafka服務(wù)器日志中找不到DEBUG 日志級別的相關(guān)日志。
-
運(yùn)行描述消費(fèi)者組命令時,出現(xiàn)以下結(jié)果:
a. 消費(fèi)群體正在重新平衡。
b. 老消費(fèi)者,有一定滯后性。
c. 具有一些隨機(jī)名稱的新消費(fèi)者。隨著時間的推移,新的消費(fèi)者數(shù)量不斷增加。
d.新消息發(fā)布在主題上,但消費(fèi)者沒有收到。
e.heartbeat 和 session.time.out 設(shè)置為默認(rèn)值。 -
如果消息在主題及其使用者的分區(qū)分配之前發(fā)布,則會出現(xiàn)此問題。
二、問題分析
-
假設(shè)應(yīng)用程序在消費(fèi)者組中具有以下消費(fèi)者:
a. 消費(fèi)者A收聽Topic1。