集群关闭并恢复后,Kafka Consumer 是否重新连接并重新订阅主题

Does Kafka Consumer reconnect and resubscribe to topics after cluster goes down and comes back up

kafka 消费者使用 librdkafka(高级消费者)连接到 kafka 集群并订阅 10 个主题并消费数据。有分配分区事件。

由于无法访问集群,出现了网络问题。与小组协调员失去联系,心跳停滞。有代码调用消费者取消分配的撤销分区事件。

当集群恢复时,消费者没有消费任何数据,尽管它在 while true 循环中调用 consume 超时为 1 秒。

消费者接入集群后是否需要重新订阅主题?在代码中检测消费者连接到集群的可靠方法是什么?

Does consumer needs to resubscribe to topics again once it is connected to cluster?

是的。新的群成员会导致现有成员之间的重新平衡,他们需要重新订阅

What is a reliable way to detect the consumer is connected to cluster in code?

您可以描述消费群体,看看您感兴趣的消费群体是否有活跃客户