Class KafkaConnectS2IUtils


  • public class KafkaConnectS2IUtils
    extends Object
    • 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)