リスナーコンテナーのパーティションの一時停止と再開

バージョン 2.7 以降では、リスナーコンテナーの pausePartition(TopicPartition topicPartition) および resumePartition(TopicPartition topicPartition) メソッドを使用して、そのコンシューマーに割り当てられた特定のパーティションの使用を一時停止および再開できます。一時停止と再開は、pause() および resume() 方法と同様に、それぞれ poll() の前後に行われます。isPartitionPauseRequested() メソッドは、そのパーティションの一時停止がリクエストされている場合に true を返します。isPartitionPaused() メソッドは、そのパーティションが事実上一時停止されている場合に true を返します。

また、バージョン 2.7 以降、ConsumerPartitionPausedEvent および ConsumerPartitionResumedEvent インスタンスは、コンテナーを source プロパティおよび TopicPartition インスタンスとして公開されます。