消費組問題
更新時間 2023-12-22 15:08:04
最近更新時間: 2023-12-22 15:08:04
分享(xiang)文(wen)章
本(ben)文主(zhu)要介紹消(xiao)費組問題。
Kafka實例是否需要創建消費組、生產者和消費者?
不需要單獨(du)創建消費(fei)組、生產者(zhe)(zhe)和消費(fei)者(zhe)(zhe),在使用時(shi)自動生成,實(shi)例創建后,直接使用即可。
連接Kafka實例后,生產消息和消費消息,請參考向Kafka實例生產消息和消費消息。
如果消息組中沒有在線的消費者(如empty狀態),是否14天后會自動被刪除?
消息組中沒有在線的消費者(如empty狀態),14天后是否會自動被刪除與offsets.retention.minutes參數有關:
- 2020年6月16日前創建的實例,offsets.retention.minutes默認為2147483646分鐘,約1491308天,消費組14天后不會被刪除。
- 2020年6月16日以及之后創建的實例,offsets.retention.minutes默認為20160分鐘,即14天,消費組14天后會自動被刪除。
原因如下: Kafka通過offsets.retention.minutes參數控制消(xiao)費(fei)組(zu)中offsets保留時間,在(zai)此時間內(nei)如果沒(mei)有(you)(you)提交(jiao)offset,offsets將會(hui)被刪除(chu)。Kafka判定(ding)消(xiao)息(xi)組(zu)中沒(mei)有(you)(you)在(zai)線的消(xiao)費(fei)者(zhe)(如empty狀態),且(qie)沒(mei)有(you)(you)offsets時,將會(hui)刪除(chu)此消(xiao)費(fei)組(zu)。
客戶端刪除消費組后,在Kafka Manager中仍可以看到此消費組?
客戶端刪(shan)除消(xiao)(xiao)費組(zu)后,此消(xiao)(xiao)費組(zu)已經被(bei)刪(shan)除了。在Kafka Manager中(zhong)仍可(ke)以看到此消(xiao)(xiao)費組(zu),是(shi)因為Kafka Manager存(cun)在緩存(cun)。
通過以(yi)下(xia)任(ren)意一種方法解決此問題(ti):
- 重啟Kafka Manager。
- Kafka Manager只顯示14天內有消費記錄的消費組,如果您不想重啟Kafka Manager,可以等待14天后Kafka Manager自動清除此消費組。