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

此外，由于版本 2.7 和实例是以容器作为属性和实例发布的。ConsumerPartitionPausedEventConsumerPartitionResumedEventsourceTopicPartition