Class KafkaMirrorMaker2Utils
- java.lang.Object
-
- io.strimzi.systemtest.utils.kafkaUtils.KafkaMirrorMaker2Utils
-
public class KafkaMirrorMaker2Utils extends Object
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static void
waitForKafkaMirrorMaker2NotReady(String clusterName)
static void
waitForKafkaMirrorMaker2Ready(String clusterName)
static void
waitForKafkaMirrorMaker2Status(String clusterName, Enum<?> state)
Wait until KafkaMirrorMaker2 will be in desired state
-
-
-
Method Detail
-
waitForKafkaMirrorMaker2Status
public static void waitForKafkaMirrorMaker2Status(String clusterName, Enum<?> state)
Wait until KafkaMirrorMaker2 will be in desired state- Parameters:
clusterName
- name of KafkaMirrorMaker2 clusterstate
- desired state
-
waitForKafkaMirrorMaker2Ready
public static void waitForKafkaMirrorMaker2Ready(String clusterName)
-
waitForKafkaMirrorMaker2NotReady
public static void waitForKafkaMirrorMaker2NotReady(String clusterName)
-
-