Class KafkaConnectS2IUtils
- java.lang.Object
-
- io.strimzi.systemtest.utils.kafkaUtils.KafkaConnectS2IUtils
-
public class KafkaConnectS2IUtils extends Object
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static voidwaitForConnectS2INotReady(String clusterName)static voidwaitForConnectS2IReady(String clusterName)static voidwaitForConnectS2IStatus(String clusterName, Enum<?> status)Wait until the given Kafka ConnectS2I cluster is in desired state.
-
-
-
Method Detail
-
waitForConnectS2IStatus
public static void waitForConnectS2IStatus(String clusterName, Enum<?> status)
Wait until the given Kafka ConnectS2I cluster is in desired state.- Parameters:
clusterName- The name of the Kafka ConnectS2I cluster.status- desired status value
-
waitForConnectS2IReady
public static void waitForConnectS2IReady(String clusterName)
-
waitForConnectS2INotReady
public static void waitForConnectS2INotReady(String clusterName)
-
-