在调用listener.resumePartiton()时不会调用onPartitonsAssigned。listener.resumePartiton()方法是用于从暂停状态恢复分区的消费,它会在消费者中重新分配分区,但不会触发onPartitonsAssigned回调函数。
onPartitonsAssigned是一个消费者的回调函数,用于在消费者加入一个消费组或者重新分配分区时被调用。它会接收到被分配的新分区列表,从而可以执行相应的操作。一般情况下,onPartitonsAssigned回调函数会在消费者刚刚加入消费组或者分区重新分配时被触发。
如果想要在调用listener.resumePartiton()时触发onPartitonsAssigned回调函数,需要在调用listener.resumePartiton()之后手动调用consumer.poll()方法来触发重新分配分区的过程,进而触发onPartitonsAssigned回调函数。
腾讯云相关产品推荐:
注意:以上推荐产品仅为示例,不代表实际使用的最佳选择,具体选择需要根据业务需求和情况进行评估。
新知·音视频技术公开课
“中小企业”在线学堂
小程序云开发官方直播课(应用开发实战)
云+社区开发者大会(苏州站)
小程序云开发官方直播课(应用开发实战)
云+社区技术沙龙[第1期]
云+社区技术沙龙[第14期]
云+社区技术沙龙[第22期]
云+社区技术沙龙[第25期]
领取专属 10元无门槛券
手把手带您无忧上云