Class KafkaMirrorMakerUtils
- java.lang.Object
-
- io.strimzi.systemtest.utils.kafkaUtils.KafkaMirrorMakerUtils
-
public class KafkaMirrorMakerUtils extends Object
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static voidwaitForKafkaMirrorMakerNotReady(String clusterName)static voidwaitForKafkaMirrorMakerReady(String clusterName)static voidwaitForKafkaMirrorMakerStatus(String clusterName, Enum<?> state)Wait until KafkaMirrorMaker status is in desired state
-
-
-
Method Detail
-
waitForKafkaMirrorMakerStatus
public static void waitForKafkaMirrorMakerStatus(String clusterName, Enum<?> state)
Wait until KafkaMirrorMaker status is in desired state- Parameters:
clusterName- name of KafkaMirrorMaker clusterstate- desired state - like Ready
-
waitForKafkaMirrorMakerReady
public static void waitForKafkaMirrorMakerReady(String clusterName)
-
waitForKafkaMirrorMakerNotReady
public static void waitForKafkaMirrorMakerNotReady(String clusterName)
-
-