Class KafkaConnectorUtils
- java.lang.Object
-
- io.strimzi.systemtest.utils.kafkaUtils.KafkaConnectorUtils
-
public class KafkaConnectorUtils extends Object
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static voidcreateFileSinkConnector(String podName, String topicName, String sinkFileName, String apiUrl)static StringgetConnectorConfig(String podName, String connectorName, String apiUrl)static StringgetConnectorSpecFromConnectAPI(String podName, String connectorName)static StringgetCreatedConnectors(String connectPodName)static StringwaitForConnectorConfigUpdate(String podName, String connectorName, String oldConfig, String apiUrl)static voidwaitForConnectorCreation(String connectS2IPodName, String connectorName)static voidwaitForConnectorDeletion(String connectorName)static voidwaitForConnectorNotReady(String connectorName)static voidwaitForConnectorReady(String connectorName)static voidwaitForConnectorStability(String connectorName, String connectPodName)WaitForStabilityConnector method, verifying stability of connectorstatic voidwaitForConnectorsTaskMaxChange(String connectorName, int taskMax)static voidwaitForConnectorStatus(String connectorName, Enum<?> state)Wait until KafkaConnector is in desired state
-
-
-
Method Detail
-
waitForConnectorStability
public static void waitForConnectorStability(String connectorName, String connectPodName)
WaitForStabilityConnector method, verifying stability of connector- Parameters:
connectorName- connector nameconnectPodName- connects2i or connect pod name
-
waitForConnectorStatus
public static void waitForConnectorStatus(String connectorName, Enum<?> state)
Wait until KafkaConnector is in desired state- Parameters:
connectorName- name of KafkaConnectorstate- desired state
-
waitForConnectorReady
public static void waitForConnectorReady(String connectorName)
-
waitForConnectorNotReady
public static void waitForConnectorNotReady(String connectorName)
-
waitForConnectorCreation
public static void waitForConnectorCreation(String connectS2IPodName, String connectorName)
-
waitForConnectorDeletion
public static void waitForConnectorDeletion(String connectorName)
-
createFileSinkConnector
public static void createFileSinkConnector(String podName, String topicName, String sinkFileName, String apiUrl)
-
waitForConnectorsTaskMaxChange
public static void waitForConnectorsTaskMaxChange(String connectorName, int taskMax)
-
getConnectorSpecFromConnectAPI
public static String getConnectorSpecFromConnectAPI(String podName, String connectorName)
-
getConnectorConfig
public static String getConnectorConfig(String podName, String connectorName, String apiUrl)
-
-