Skip to content

Commit

Permalink
Update systemtest/src/main/java/io/strimzi/systemtest/utils/kafkaUtil…
Browse files Browse the repository at this point in the history
…s/KafkaUtils.java

Co-authored-by: Lukáš Král <[email protected]>
Signed-off-by: Maros Orsak <[email protected]>
  • Loading branch information
see-quick and im-konge authored Oct 21, 2024
1 parent d225b72 commit 8e8e0f0
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -660,7 +660,7 @@ public static void waitUntilKafkaHasAutoRebalanceState(final String namespaceNam
final String clusterName,
final KafkaAutoRebalanceState expectedState) {
TestUtils.waitFor(
String.format("waiting for Kafka cluster '%s' in namespace '%s' and KafkaRebalance state: '%s'", clusterName, namespaceName, expectedState),
String.format("Kafka cluster: '%s' in Namespace: '%s' and KafkaRebalance state: '%s'", clusterName, namespaceName, expectedState),
TestConstants.GLOBAL_POLL_INTERVAL,
TestConstants.GLOBAL_TIMEOUT,
() -> {
Expand Down

0 comments on commit 8e8e0f0

Please sign in to comment.