Class KafkaBridgeResource


  • public class KafkaBridgeResource
    extends Object
    • Field Detail

      • PATH_TO_KAFKA_BRIDGE_CONFIG

        public static final String PATH_TO_KAFKA_BRIDGE_CONFIG
      • PATH_TO_KAFKA_BRIDGE_METRICS_CONFIG

        public static final String PATH_TO_KAFKA_BRIDGE_METRICS_CONFIG
    • Constructor Detail

      • KafkaBridgeResource

        public KafkaBridgeResource()
    • Method Detail

      • kafkaBridgeClient

        public static io.fabric8.kubernetes.client.dsl.MixedOperation<io.strimzi.api.kafka.model.KafkaBridge,​io.strimzi.api.kafka.KafkaBridgeList,​io.fabric8.kubernetes.client.dsl.Resource<io.strimzi.api.kafka.model.KafkaBridge>> kafkaBridgeClient()
      • kafkaBridge

        public static io.strimzi.api.kafka.model.KafkaBridgeBuilder kafkaBridge​(String name,
                                                                                String bootstrap,
                                                                                int kafkaBridgeReplicas)
      • kafkaBridge

        public static io.strimzi.api.kafka.model.KafkaBridgeBuilder kafkaBridge​(String name,
                                                                                String clusterName,
                                                                                String bootstrap,
                                                                                int kafkaBridgeReplicas)
      • kafkaBridgeWithCors

        public static io.strimzi.api.kafka.model.KafkaBridgeBuilder kafkaBridgeWithCors​(String name,
                                                                                        String bootstrap,
                                                                                        int kafkaBridgeReplicas,
                                                                                        String allowedCorsOrigin,
                                                                                        String allowedCorsMethods)
      • kafkaBridgeWithCors

        public static io.strimzi.api.kafka.model.KafkaBridgeBuilder kafkaBridgeWithCors​(String name,
                                                                                        String clusterName,
                                                                                        String bootstrap,
                                                                                        int kafkaBridgeReplicas,
                                                                                        String allowedCorsOrigin,
                                                                                        String allowedCorsMethods)
      • kafkaBridgeWithMetrics

        public static io.strimzi.api.kafka.model.KafkaBridgeBuilder kafkaBridgeWithMetrics​(String name,
                                                                                           String clusterName,
                                                                                           String bootstrap)
      • kafkaBridgeWithMetrics

        public static io.strimzi.api.kafka.model.KafkaBridgeBuilder kafkaBridgeWithMetrics​(String name,
                                                                                           String clusterName,
                                                                                           String bootstrap,
                                                                                           int kafkaBridgeReplicas)
      • createAndWaitForReadiness

        public static io.strimzi.api.kafka.model.KafkaBridge createAndWaitForReadiness​(io.strimzi.api.kafka.model.KafkaBridge kafkaBridge)
      • kafkaBridgeWithoutWait

        public static io.strimzi.api.kafka.model.KafkaBridge kafkaBridgeWithoutWait​(io.strimzi.api.kafka.model.KafkaBridge kafkaBridge)
      • deleteKafkaBridgeWithoutWait

        public static void deleteKafkaBridgeWithoutWait​(String resourceName)
      • replaceBridgeResource

        public static void replaceBridgeResource​(String resourceName,
                                                 Consumer<io.strimzi.api.kafka.model.KafkaBridge> editor)