Class KafkaMirrorMaker2Utils


  • public class KafkaMirrorMaker2Utils
    extends Object
    • Method Detail

      • waitForKafkaMirrorMaker2Status

        public static void waitForKafkaMirrorMaker2Status​(String clusterName,
                                                          Enum<?> state)
        Wait until KafkaMirrorMaker2 will be in desired state
        Parameters:
        clusterName - name of KafkaMirrorMaker2 cluster
        state - desired state
      • waitForKafkaMirrorMaker2Ready

        public static void waitForKafkaMirrorMaker2Ready​(String clusterName)
      • waitForKafkaMirrorMaker2NotReady

        public static void waitForKafkaMirrorMaker2NotReady​(String clusterName)