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 void
waitForKafkaMirrorMakerNotReady(String clusterName)
static void
waitForKafkaMirrorMakerReady(String clusterName)
static void
waitForKafkaMirrorMakerStatus(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)
-
-