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