Class KafkaUserUtils
- java.lang.Object
-
- io.strimzi.systemtest.utils.kafkaUtils.KafkaUserUtils
-
public class KafkaUserUtils extends Object
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static StringgenerateRandomNameOfKafkaUser()Generated random name for the KafkaUser resourcestatic voidwaitForKafkaUserCreation(String userName)static voidwaitForKafkaUserDeletion(String userName)static voidwaitForKafkaUserIncreaseObserverGeneration(long observation, String userName)static voidwaitForKafkaUserNotReady(String userName)static voidwaitForKafkaUserReady(String userName)static voidwaitForKafkaUserStatus(String userName, Enum<?> state)Wait until KafkaUser is in desired statestatic voidwaitUntilKafkaUserStatusConditionIsPresent(String userName)
-
-
-
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 KafkaUserstate- desired state
-
waitForKafkaUserReady
public static void waitForKafkaUserReady(String userName)
-
waitForKafkaUserNotReady
public static void waitForKafkaUserNotReady(String userName)
-
-