在監聽器容器上暫停和恢復分區

自 2.7 版本起，您可以使用監聽器容器中的 pausePartition(TopicPartition topicPartition) 和 resumePartition(TopicPartition topicPartition) 方法，暫停和恢復消費分配給該消費者的特定分區。暫停和恢復分別在 poll() 之前和之後發生，類似於 pause() 和 resume() 方法。如果已請求暫停該分區，isPartitionPauseRequested() 方法會返回 true。如果該分區已實際暫停，isPartitionPaused() 方法會返回 true。

此外，自 2.7 版本起，ConsumerPartitionPausedEvent 和 ConsumerPartitionResumedEvent 實例會發布，容器作為 source 屬性，以及 TopicPartition 實例。