為什么Group不存在但能消費消息?
更新時間 2024-01-05 15:52:25
最近更新時間: 2024-01-05 15:52:25
分享文章
本節介紹Group不存在但能消費消息原因
我在分布式消息服務Kafka控制臺上,未查看到對應的Group,但此Group下卻有消費線程在消費消息。
可能原因
- 如果客戶端使用assign方式消費消息,那么即使不創建Group,也可能消費消息。
- 如果客戶端使用subscribe方式消費消息,刪除Group后,消費線程未停止或者未發生Rebalance,那么消費線程還可以繼續正常消費。
解決方案
- 如果客戶端使用assign方式消費消息,請提前在分布式消息服務Kafka控制臺創建Group。
- 請盡量復用Group,避免創建過多的Group而影響集群的穩定性。
- 在刪除Group前,請確保已停止該Group下的所有消費線程。