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

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

同样从 2.7 版开始，ConsumerPartitionPausedEvent 和 ConsumerPartitionResumedEvent 实例会发布，其中容器作为 source 属性，TopicPartition 实例作为事件数据。