You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2022/08/10 14:20:26 UTC
[kafka] 01/01: MINOR: Remove spurious sleep in ConsumerCoordinatorTest
This is an automated email from the ASF dual-hosted git repository.
ijuma pushed a commit to branch 12349-test-cleanup
in repository https://gitbox.apache.org/repos/asf/kafka.git
commit b1dc644ba6b6c0f74301aea7e272e125bd061b8c
Author: Ismael Juma <is...@juma.me.uk>
AuthorDate: Wed Aug 10 07:20:17 2022 -0700
MINOR: Remove spurious sleep in ConsumerCoordinatorTest
Follow up from here https://github.com/apache/kafka/pull/12349#discussion_r925138410
---
.../apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java
index d948990d69b..2b696087b84 100644
--- a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java
+++ b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java
@@ -1348,7 +1348,6 @@ public abstract class ConsumerCoordinatorTest {
String memberId = "consumer-42";
Timer pollTimer = time.timer(100L);
- time.sleep(150);
boolean res = coordinator.onJoinPrepare(pollTimer, generationId, memberId);
assertFalse(res);