パッケージ org.springframework.kafka.test.utils

クラス ContainerTestUtils

java.lang.ObjectSE
org.springframework.kafka.test.utils.ContainerTestUtils
public final class ContainerTestUtils extends ObjectSE
リスナーコンテナーをテストするためのユーティリティ。プロジェクトの循環依存関係を回避するために、コンテナークラスへのハード参照は使用されません。
導入:
1.0.3
作成者:
Gary Russell

  • メソッドの詳細

    • waitForAssignment

      public static void waitForAssignment(ObjectSE container, int partitions)
      コンテナーに必要な数のパーティションが割り当てられるまで待ちます。
      パラメーター:
      container - コンテナー。
      partitions - パーティションの数。
      例外:
      IllegalStateExceptionSE - （2.3.4 以降）期待どおりに操作を完了できない場合。
      org.springframework.kafka.test.utils.ContainerTestUtils.ContainerTestUtilsException - コンテナーの getAssignedPartitions() メソッドの呼び出しが失敗した場合。