|
这个版本仍在开发中，目前尚未被认为是稳定的。要使用最新稳定版本，请使用 Spring for Apache Kafka 4.0.4！ |
暂停并恢复监听器容器中的分区
自 2.7 版本起，您可以使用监听器容器中 pausePartition(TopicPartition topicPartition) 和 resumePartition(TopicPartition topicPartition) 方法暂停和恢复该消费者分配的特定分区的消费。
暂停和恢复分别在 poll() 之前和之后进行，类似于 pause() 和 resume() 方法。
isPartitionPauseRequested() 方法在请求暂停该分区时返回 true。
isPartitionPaused() 方法在该分区实际被暂停时返回 true。
自从2.7版本开始，ConsumerPartitionPausedEvent和ConsumerPartitionResumedEvent实例将作为容器的source属性和TopicPartition实例发布。