2017-07-19 16 views
0
  1. 如何獲取消費者連接的分區?
  2. 如果訂閱了多個主題,如何從consumer.metrics()獲取不同主題的指標(傳入字節率)?

回答

1
  1. 如果你是一個消費羣體的一部分,並利用在自動分區分配,每次分區分配(由於再平衡),該onPartitionsAssigned()(在ConsumerRebalanceListener的)被稱爲與收集分配的分區。 順便說一句,你可以在任何時候調用assign()方法來獲得分配的分區。
  2. 不太確定,但是,方法metrics()應該可以完成這項工作。