|
对于最新稳定版本，请使用 Spring for Apache Kafka 4.0.0！ |
在监听器容器上暂停和恢复分区
自2.7版本起，您可以通过以下方式暂停并恢复分配给该消费者的特定分区的消费pausePartition（TopicPartition topicPartition）和resumePartition（TopicPartition topicPartition）方法在监听器容器中。
暂停和恢复分别发生在poll（）类似于暂停（pause）和简历（）方法。
这isPartitionPauseRequested（）如果请求该分区暂停，方法返回为真。
这isPartitionPaused（）如果该分区实际上被暂停，方法返回真。
自2.7版本起ConsumerPartitionPausedEvent和ConsumerPartitionResumedEvent实例以容器的形式发布源财产和主题分区实例。