暂停和恢复侦听器容器上的分区
从版本 2.7 开始,您可以使用pausePartition(TopicPartition topicPartition)和resumePartition(TopicPartition topicPartition)方法。
暂停和恢复分别发生在poll()类似于pause()和resume()方法。
这isPartitionPauseRequested()method 如果已请求该分区的 pause,则返回 true。
这isPartitionPaused()method 如果该分区已有效暂停,则返回 true。
同样从 2.7 版本开始ConsumerPartitionPausedEvent和ConsumerPartitionResumedEvent实例与容器一起发布,作为sourceproperty 和TopicPartition实例。