暂停并恢复监听器容器中的分区
自 2.7 版本起,您可以使用监听器容器中 pausePartition(TopicPartition topicPartition) 和 resumePartition(TopicPartition topicPartition) 方法暂停和恢复该消费者分配的特定分区的消费。
暂停和恢复分别在 poll() 之前和之后进行,类似于 pause() 和 resume() 方法。
isPartitionPauseRequested() 方法在请求暂停该分区时返回 true。
isPartitionPaused() 方法在该分区实际被暂停时返回 true。
自从2.7版本开始,ConsumerPartitionPausedEvent和ConsumerPartitionResumedEvent实例将作为容器的source属性和TopicPartition实例发布。