Class KafkaMirrorMaker2Resource


  • public class KafkaMirrorMaker2Resource
    extends Object
    • Field Detail

      • PATH_TO_KAFKA_MIRROR_MAKER_2_CONFIG

        public static final String PATH_TO_KAFKA_MIRROR_MAKER_2_CONFIG
    • Constructor Detail

      • KafkaMirrorMaker2Resource

        public KafkaMirrorMaker2Resource()
    • Method Detail

      • kafkaMirrorMaker2Client

        public static io.fabric8.kubernetes.client.dsl.MixedOperation<io.strimzi.api.kafka.model.KafkaMirrorMaker2,​io.strimzi.api.kafka.KafkaMirrorMaker2List,​io.fabric8.kubernetes.client.dsl.Resource<io.strimzi.api.kafka.model.KafkaMirrorMaker2>> kafkaMirrorMaker2Client()
      • kafkaMirrorMaker2

        public static io.strimzi.api.kafka.model.KafkaMirrorMaker2Builder kafkaMirrorMaker2​(String name,
                                                                                            String targetClusterName,
                                                                                            String sourceClusterName,
                                                                                            int kafkaMirrorMaker2Replicas,
                                                                                            boolean tlsListener)
      • kafkaMirrorMaker2WithMetrics

        public static io.strimzi.api.kafka.model.KafkaMirrorMaker2Builder kafkaMirrorMaker2WithMetrics​(String name,
                                                                                                       String targetClusterName,
                                                                                                       String sourceClusterName,
                                                                                                       int kafkaMirrorMaker2Replicas)
      • createAndWaitForReadiness

        public static io.strimzi.api.kafka.model.KafkaMirrorMaker2 createAndWaitForReadiness​(io.strimzi.api.kafka.model.KafkaMirrorMaker2 kafkaMirrorMaker2)
      • kafkaMirrorMaker2WithoutWait

        public static io.strimzi.api.kafka.model.KafkaMirrorMaker2 kafkaMirrorMaker2WithoutWait​(io.strimzi.api.kafka.model.KafkaMirrorMaker2 kafkaMirrorMaker2)
      • deleteKafkaMirrorMaker2WithoutWait

        public static void deleteKafkaMirrorMaker2WithoutWait​(String resourceName)
      • replaceKafkaMirrorMaker2Resource

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