java - 消费者连接到哪个分区？

Question

1. 如何获取消费者连接的分区？
2. 如果订阅了多个主题，如何从consumer.metrics()获取不同主题的指标(传入字节率)？

Answer 1

1. 如果您是消费者组的一部分并且正在利用自动分区分配，则每次分配分区(由于重新平衡)时，都会调用 onPartitionsAssigned() (ConsumerRebalanceListener 的)并收集分配的分区。 顺便说一句，您可以随时调用分配()方法来获取分配的分区。
2. 不太确定，但是是的，metrics() 方法应该可以完成这项工作。