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

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

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