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