一、場景

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。