Class KafkaUserUtils


  • public class KafkaUserUtils
    extends Object
    • Method Detail

      • generateRandomNameOfKafkaUser

        public static String generateRandomNameOfKafkaUser()
        Generated random name for the KafkaUser resource
        Returns:
        random name with additional salt
      • waitForKafkaUserCreation

        public static void waitForKafkaUserCreation​(String userName)
      • waitForKafkaUserDeletion

        public static void waitForKafkaUserDeletion​(String userName)
      • waitForKafkaUserIncreaseObserverGeneration

        public static void waitForKafkaUserIncreaseObserverGeneration​(long observation,
                                                                      String userName)
      • waitUntilKafkaUserStatusConditionIsPresent

        public static void waitUntilKafkaUserStatusConditionIsPresent​(String userName)
      • waitForKafkaUserStatus

        public static void waitForKafkaUserStatus​(String userName,
                                                  Enum<?> state)
        Wait until KafkaUser is in desired state
        Parameters:
        userName - name of KafkaUser
        state - desired state
      • waitForKafkaUserReady

        public static void waitForKafkaUserReady​(String userName)
      • waitForKafkaUserNotReady

        public static void waitForKafkaUserNotReady​(String userName)