卡夫卡在删除组时不会停止消费者

卡夫卡在删除组时不会停止消费者

我将日志从 Logstash 作为生产者发送到 Kafka,然后从 Graylog 消费它们。这按预期工作。

但是,当停止 Graylog 输入并发送 LeaveGroup 请求时,消费者不会取消注册,即使通过 删除该组bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --delete --group graylog2,Graylog 仍会继续使用(并且能够这样做),即使该组graylog2不再存在。

这是预期的行为吗?在这种情况下,注销消费者的正确方法是什么?

相关内容