暫停和恢復監聽器容器上的分割槽

自 2.7 版本起，您可以透過監聽器容器中的 pausePartition(TopicPartition topicPartition) 和 resumePartition(TopicPartition topicPartition) 方法來暫停和恢復消費者所分配的特定分割槽的消費。暫停和恢復分別在 poll() 方法之前和之後發生，類似於 pause() 和 resume() 方法。isPartitionPauseRequested() 方法在請求暫停該分割槽時返回 true。isPartitionPaused() 方法在該分割槽已有效暫停時返回 true。

同樣自 2.7 版本起，ConsumerPartitionPausedEvent 和 ConsumerPartitionResumedEvent 例項將釋出，其中容器作為 source 屬性，幷包含 TopicPartition 例項。