![卡夫卡在删除组时不会停止消费者](https://linux22.com/image/787669/%E5%8D%A1%E5%A4%AB%E5%8D%A1%E5%9C%A8%E5%88%A0%E9%99%A4%E7%BB%84%E6%97%B6%E4%B8%8D%E4%BC%9A%E5%81%9C%E6%AD%A2%E6%B6%88%E8%B4%B9%E8%80%85.png)
我将日志从 Logstash 作为生产者发送到 Kafka,然后从 Graylog 消费它们。这按预期工作。
但是,当停止 Graylog 输入并发送 LeaveGroup 请求时,消费者不会取消注册,即使通过 删除该组bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --delete --group graylog2
,Graylog 仍会继续使用(并且能够这样做),即使该组graylog2
不再存在。
这是预期的行为吗?在这种情况下,注销消费者的正确方法是什么?