Class KafkaMirrorMakerUtils


  • public class KafkaMirrorMakerUtils
    extends Object
    • Method Detail

      • waitForKafkaMirrorMakerStatus

        public static void waitForKafkaMirrorMakerStatus​(String clusterName,
                                                         Enum<?> state)
        Wait until KafkaMirrorMaker status is in desired state
        Parameters:
        clusterName - name of KafkaMirrorMaker cluster
        state - desired state - like Ready
      • waitForKafkaMirrorMakerReady

        public static void waitForKafkaMirrorMakerReady​(String clusterName)
      • waitForKafkaMirrorMakerNotReady

        public static void waitForKafkaMirrorMakerNotReady​(String clusterName)