|
对于最新的稳定版本，请使用 Spring for Apache Kafka 3.3.0！ |
暂停和恢复侦听器容器上的分区
从版本 2.7 开始，您可以通过使用侦听器容器中的 and 方法来暂停和恢复分配给该使用者的特定分区的使用。
暂停和恢复分别发生在与 和 方法类似的 之前和之后。
如果已请求该分区的 pause，则该方法返回 true。
如果该分区已有效暂停，则该方法返回 true。pausePartition(TopicPartition topicPartition)resumePartition(TopicPartition topicPartition)poll()pause()resume()isPartitionPauseRequested()isPartitionPaused()
此外，从版本 2.7 开始，实例以容器作为属性和实例发布。ConsumerPartitionPausedEventConsumerPartitionResumedEventsourceTopicPartition