|
此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 Spring for Apache Kafka 3.3.0！ |
暂停和恢复侦听器容器上的分区
从版本 2.7 开始，您可以使用pausePartition(TopicPartition topicPartition)和resumePartition(TopicPartition topicPartition)方法。
暂停和恢复分别发生在poll()类似于pause()和resume()方法。
这isPartitionPauseRequested()method 如果已请求该分区的 pause，则返回 true。
这isPartitionPaused()method 如果该分区已有效暂停，则返回 true。
同样从 2.7 版本开始ConsumerPartitionPausedEvent和ConsumerPartitionResumedEvent实例与容器一起发布，作为sourceproperty 和TopicPartition实例。