0

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

由于无法访问哪个集群而出现网络问题。与小组协调员失去联系，心跳卡住了。有撤销分区事件，其中代码对消费者调用 unassign。

当集群重新启动时，消费者没有消耗任何数据，尽管它在 while true 循环中调用消耗，超时为 1 秒。

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

4

1 回答 1

2

消费者连接集群后是否需要重新订阅主题？

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

检测消费者是否在代码中连接到集群的可靠方法是什么？

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

于 2020-01-28T20:54:44.523 回答