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

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

同样自 2.7 版本起，ConsumerPartitionPausedEvent 和 ConsumerPartitionResumedEvent 实例将发布，其中容器作为 source 属性，并包含 TopicPartition 实例。