我在分布式消息服务Kafka控制台上,未查看到对应的Group,但此Group下却有消费线程在消费消息。
可能原因
- 如果客户端使用assign方式消费消息,那么即使不创建Group,也可能消费消息。
- 如果客户端使用subscribe方式消费消息,删除Group后,消费线程未停止或者未发生Rebalance,那么消费线程还可以继续正常消费。
解决方案
- 如果客户端使用assign方式消费消息,请提前在分布式消息服务Kafka控制台创建Group。
- 请尽量复用Group,避免创建过多的Group而影响集群的稳定性。
- 在删除Group前,请确保已停止该Group下的所有消费线程。