在监听器容器上暂停和恢复分区

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

同样自版本 2.7 起,会发布 ConsumerPartitionPausedEventConsumerPartitionResumedEvent 实例,其中容器作为 source 属性,并包含 TopicPartition 实例。