暂停和恢复监听器容器上的分区

从 2.7 版本开始，您可以使用监听器容器中的 pausePartition(TopicPartition topicPartition) 和 resumePartition(TopicPartition topicPartition) 方法暂停和恢复分配给该消费者的特定分区的消费。暂停和恢复分别在 poll() 方法之前和之后进行，类似于 pause() 和 resume() 方法。isPartitionPauseRequested() 方法如果已请求暂停该分区，则返回 true。isPartitionPaused() 方法如果该分区已有效暂停，则返回 true。

从 2.7 版本开始，ConsumerPartitionPausedEvent 和 ConsumerPartitionResumedEvent 实例会以容器作为 source 属性和 TopicPartition 实例发布。