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