在监听器容器上暂停和恢复分区
自版本 2.7 起,您可以在监听器容器中使用 pausePartition(TopicPartition topicPartition)
和 resumePartition(TopicPartition topicPartition)
方法来暂停和恢复分配给该 consumer 的特定分区的消费。暂停和恢复分别发生在 poll()
之前和之后,类似于 pause()
和 resume()
方法。如果已请求暂停该分区,则 isPartitionPauseRequested()
方法返回 true。如果该分区已实际暂停,则 isPartitionPaused()
方法返回 true。
同样自版本 2.7 起,会发布 ConsumerPartitionPausedEvent
和 ConsumerPartitionResumedEvent
实例,其中容器作为 source
属性,并包含 TopicPartition
实例。