Kafka消费者重新连接和重新订阅主题后，集群去和回来

p5cysglq 于 2021-06-05 发布在 Kafka

关注(0)|答案(1)|浏览(409)

Kafka消费者使用librdkafka（高级消费者）连接到Kafka集群，订阅10个主题和消费数据。发生分配分区事件。
由于无法访问哪个群集而出现网络问题。与小组协调人失去联系，心跳停止。发生了一个事件，代码在该事件中对使用者调用unassign。
当群集恢复时，使用者没有使用任何数据，尽管它在while true循环中调用consume，超时为1秒。
消费者连接到群集后是否需要重新订阅主题？什么是可靠的方法来检测消费者连接到集群的代码？

apache-kafka librdkafka

来源：https://stackoverflow.com/questions/59953766/does-kafka-consumer-reconnect-and-resubscribe-to-topics-after-cluster-goes-down