获取Kafka分配的分区

Question

我正在使用 Quarkus Kafka 消费者。我需要知道我的消费者已经被 Kafka 代理分配到了哪些分区。 我可以使用的任何监听器，就像 Kafka 客户端提供的监听器一样。 否则如何在集群的每个节点中分配特定分区？

问候

Answer 1

从 Quarkus 文档中，我认为您可以使用重新平衡侦听器。 应该调用它，因为将分区初始分配给客户端（从无分区到某些分区）也可以视为重新平衡。

https://quarkus.io/guides/kafka#consumer-rebalance-listener

每次消费者主题/分区分配更改时都会调用侦听器。例如，当应用程序启动时，它使用与消费者关联的初始主题/分区集调用 partitionsAssigned 回调。如果稍后这个集合发生变化，它会再次调用 partitionsRevoked 和 partitionsAssigned 回调，这样您就可以实现自定义逻辑。