Class KafkaRebalanceUtils


  • public class KafkaRebalanceUtils
    extends Object
    • Method Detail

      • waitForKafkaRebalanceCustomResourceState

        public static void waitForKafkaRebalanceCustomResourceState​(String resourceName,
                                                                    io.strimzi.api.kafka.model.balancing.KafkaRebalanceState state)
      • annotateKafkaRebalanceResource

        public static String annotateKafkaRebalanceResource​(String resourceName,
                                                            io.strimzi.api.kafka.model.balancing.KafkaRebalanceAnnotation annotation)