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 void
waitForConnectS2INotReady(String clusterName)
static void
waitForConnectS2IReady(String clusterName)
static void
waitForConnectS2IStatus(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)
-
-