Class KafkaMirrorMakerResource


  • public class KafkaMirrorMakerResource
    extends Object
    • Field Detail

      • PATH_TO_KAFKA_MIRROR_MAKER_CONFIG

        public static final String PATH_TO_KAFKA_MIRROR_MAKER_CONFIG
    • Constructor Detail

      • KafkaMirrorMakerResource

        public KafkaMirrorMakerResource()
    • Method Detail

      • kafkaMirrorMakerClient

        public static io.fabric8.kubernetes.client.dsl.MixedOperation<io.strimzi.api.kafka.model.KafkaMirrorMaker,​io.strimzi.api.kafka.KafkaMirrorMakerList,​io.fabric8.kubernetes.client.dsl.Resource<io.strimzi.api.kafka.model.KafkaMirrorMaker>> kafkaMirrorMakerClient()
      • kafkaMirrorMaker

        public static io.strimzi.api.kafka.model.KafkaMirrorMakerBuilder kafkaMirrorMaker​(String name,
                                                                                          String sourceBootstrapServer,
                                                                                          String targetBootstrapServer,
                                                                                          String groupId,
                                                                                          int mirrorMakerReplicas,
                                                                                          boolean tlsListener)
      • createAndWaitForReadiness

        public static io.strimzi.api.kafka.model.KafkaMirrorMaker createAndWaitForReadiness​(io.strimzi.api.kafka.model.KafkaMirrorMaker kafkaMirrorMaker)
      • kafkaMirrorMakerWithoutWait

        public static io.strimzi.api.kafka.model.KafkaMirrorMaker kafkaMirrorMakerWithoutWait​(io.strimzi.api.kafka.model.KafkaMirrorMaker kafkaMirrorMaker)
      • deleteKafkaMirrorMakerWithoutWait

        public static void deleteKafkaMirrorMakerWithoutWait​(String resourceName)
      • replaceMirrorMakerResource

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