Class KafkaTopicUtils
- java.lang.Object
-
- io.strimzi.systemtest.utils.kafkaUtils.KafkaTopicUtils
-
public class KafkaTopicUtils extends Object
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static StringgenerateRandomNameOfTopic()Generated random name for the KafkaTopic resourcestatic StringtopicSnapshot(String topicName)Method which return UID for specific topicstatic voidwaitForKafkaTopicCreation(String topicName)static voidwaitForKafkaTopicCreationByNamePrefix(String topicNamePrefix)static voidwaitForKafkaTopicDeletion(String topicName)static voidwaitForKafkaTopicNotReady(String topicName)static voidwaitForKafkaTopicPartitionChange(String topicName, int partitions)static voidwaitForKafkaTopicReady(String topicName)static voidwaitForKafkaTopicsCount(int topicCount, String clusterName)static voidwaitForKafkaTopicStatus(String topicName, Enum<?> state)Wait until KafkaTopic is in desired statusstatic StringwaitTopicHasRolled(String topicName, String topicUid)Method which wait until topic has rolled form one generation to another.
-
-
-
Method Detail
-
generateRandomNameOfTopic
public static String generateRandomNameOfTopic()
Generated random name for the KafkaTopic resource- Returns:
- random name with additional salt
-
topicSnapshot
public static String topicSnapshot(String topicName)
Method which return UID for specific topic- Parameters:
topicName- topic name- Returns:
- topic UID
-
waitTopicHasRolled
public static String waitTopicHasRolled(String topicName, String topicUid)
Method which wait until topic has rolled form one generation to another.- Parameters:
topicName- topic nametopicUid- topic UID- Returns:
- topic new UID
-
waitForKafkaTopicCreation
public static void waitForKafkaTopicCreation(String topicName)
-
waitForKafkaTopicCreationByNamePrefix
public static void waitForKafkaTopicCreationByNamePrefix(String topicNamePrefix)
-
waitForKafkaTopicDeletion
public static void waitForKafkaTopicDeletion(String topicName)
-
waitForKafkaTopicPartitionChange
public static void waitForKafkaTopicPartitionChange(String topicName, int partitions)
-
waitForKafkaTopicStatus
public static void waitForKafkaTopicStatus(String topicName, Enum<?> state)
Wait until KafkaTopic is in desired status- Parameters:
topicName- name of KafkaTopicstate- desired state
-
waitForKafkaTopicReady
public static void waitForKafkaTopicReady(String topicName)
-
waitForKafkaTopicNotReady
public static void waitForKafkaTopicNotReady(String topicName)
-
waitForKafkaTopicsCount
public static void waitForKafkaTopicsCount(int topicCount, String clusterName)
-
-