Class CruiseControlUtils


  • public class CruiseControlUtils
    extends Object
    • Field Detail

      • CRUISE_CONTROL_MODEL_TRAINING_SAMPLES_TOPIC

        public static final String CRUISE_CONTROL_MODEL_TRAINING_SAMPLES_TOPIC
        See Also:
        Constant Field Values
      • CRUISE_CONTROL_PARTITION_METRICS_SAMPLES_TOPIC

        public static final String CRUISE_CONTROL_PARTITION_METRICS_SAMPLES_TOPIC
        See Also:
        Constant Field Values
    • Method Detail

      • verifyCruiseControlMetricReporterConfigurationInKafkaConfigMapIsPresent

        public static void verifyCruiseControlMetricReporterConfigurationInKafkaConfigMapIsPresent​(Properties kafkaProperties)
      • verifyThatCruiseControlSamplesTopicsArePresent

        public static void verifyThatCruiseControlSamplesTopicsArePresent​(long timeout)
      • verifyThatKafkaCruiseControlMetricReporterTopicIsPresent

        public static void verifyThatKafkaCruiseControlMetricReporterTopicIsPresent​(long timeout)
      • verifyThatCruiseControlTopicsArePresent

        public static void verifyThatCruiseControlTopicsArePresent()
      • getKafkaCruiseControlMetricsReporterConfiguration

        public static Properties getKafkaCruiseControlMetricsReporterConfiguration​(String clusterName)
                                                                            throws IOException
        Throws:
        IOException
      • waitForRebalanceEndpointIsReady

        public static void waitForRebalanceEndpointIsReady()