Skip to content

Commit

Permalink
Lukas review
Browse files Browse the repository at this point in the history
Signed-off-by: see-quick <[email protected]>
  • Loading branch information
see-quick committed Oct 21, 2024
1 parent d225b72 commit eb6695f
Showing 1 changed file with 3 additions and 3 deletions.
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/%s and KafkaRebalance state: '%s'", clusterName, namespaceName, expectedState),
TestConstants.GLOBAL_POLL_INTERVAL,
TestConstants.GLOBAL_TIMEOUT,
() -> {
Expand Down Expand Up @@ -690,8 +690,8 @@ public static void waitUntilKafkaHasExpectedAutoRebalanceModeAndBrokers(final St
final KafkaRebalanceMode expectedKafkaAutoRebalanceMode,
final List<Integer> scalingBrokers) {
TestUtils.waitFor(
String.format("Waiting for Kafka cluster '%s' in namespace '%s' and KafkaRebalance mode '%s' with brokers %s",
clusterName, namespaceName, expectedKafkaAutoRebalanceMode, scalingBrokers),
String.format("Kafka cluster %s/%s and KafkaRebalance mode '%s' with brokers %s",
namespaceName, clusterName, expectedKafkaAutoRebalanceMode, scalingBrokers),
TestConstants.GLOBAL_POLL_INTERVAL,
TestConstants.GLOBAL_TIMEOUT,
() -> {
Expand Down

0 comments on commit eb6695f

Please sign in to comment.