Class KafkaBridgeUtils


  • public class KafkaBridgeUtils
    extends Object
    • Method Detail

      • getBridgeNodePort

        public static int getBridgeNodePort​(String namespace,
                                            String bridgeExternalService)
      • createBridgeNodePortService

        public static io.fabric8.kubernetes.api.model.Service createBridgeNodePortService​(String clusterName,
                                                                                          String namespace,
                                                                                          String serviceName)
      • checkSendResponse

        public static void checkSendResponse​(io.vertx.core.json.JsonObject response,
                                             int messageCount)
      • waitForKafkaBridgeStatus

        public static void waitForKafkaBridgeStatus​(String clusterName,
                                                    Enum<?> state)
        Wait until KafkaBridge is in desired state
        Parameters:
        clusterName - name of KafkaBridge cluster
        state - desired state
      • waitForKafkaBridgeReady

        public static void waitForKafkaBridgeReady​(String clusterName)
      • waitForKafkaBridgeNotReady

        public static void waitForKafkaBridgeNotReady​(String clusterName)