对于最新的稳定版本,请使用 Spring for Apache Kafka 3.2.1Spring中文文档

对于最新的稳定版本,请使用 Spring for Apache Kafka 3.2.1Spring中文文档

从版本 2.7 开始,您可以使用侦听器容器中的 和 方法暂停和恢复分配给该使用者的特定分区的使用。 暂停和恢复分别发生在与 和 方法类似的之前和之后。 如果已请求暂停该分区,则该方法返回 true。 如果该分区已有效暂停,则该方法返回 true。pausePartition(TopicPartition topicPartition)resumePartition(TopicPartition topicPartition)poll()pause()resume()isPartitionPauseRequested()isPartitionPaused()Spring中文文档

此外,由于版本 2.7 和实例是以容器作为属性和实例发布的。ConsumerPartitionPausedEventConsumerPartitionResumedEventsourceTopicPartitionSpring中文文档