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

自版本 2.7 起，您可以在监听器容器中使用 pausePartition(TopicPartition topicPartition) 和 resumePartition(TopicPartition topicPartition) 方法来暂停和恢复分配给该 consumer 的特定分区的消费。暂停和恢复分别发生在 poll() 之前和之后，类似于 pause() 和 resume() 方法。如果已请求暂停该分区，则 isPartitionPauseRequested() 方法返回 true。如果该分区已实际暂停，则 isPartitionPaused() 方法返回 true。

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