クラス ContainerTestUtils
java.lang.ObjectSE
org.springframework.kafka.test.utils.ContainerTestUtils
リスナーコンテナーをテストするためのユーティリティ。プロジェクトの循環依存関係を回避するために、コンテナークラスへのハード参照は使用されません。
- 導入:
- 1.0.3
- 作成者:
- Gary Russell
メソッドのサマリー
修飾子と型メソッド説明static void
waitForAssignment
(ObjectSE container, int partitions) コンテナーに必要な数のパーティションが割り当てられるまで待ちます。
メソッドの詳細
waitForAssignment
コンテナーに必要な数のパーティションが割り当てられるまで待ちます。- パラメーター:
container
- コンテナー。partitions
- パーティションの数。- 例外:
IllegalStateExceptionSE
- (2.3.4 以降)期待どおりに操作を完了できない場合。org.springframework.kafka.test.utils.ContainerTestUtils.ContainerTestUtilsException
- コンテナーの getAssignedPartitions() メソッドの呼び出しが失敗した場合。