This is an automated email from the ASF dual-hosted git repository.
showuon pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new bc50f70219 remove sleep in test (#12525)
bc50f70219 is described below
commit bc50f7021990654aa04ba72859a29d816720d19a
Author: Luke Chen <[email protected]>
AuthorDate: Fri Aug 19 14:17:33 2022 +0800
remove sleep in test (#12525)
Remove spurious sleep in ConsumerCoordinatorTest
Reviewers: Ismael Juma <[email protected]>
---
.../kafka/clients/consumer/internals/ConsumerCoordinatorTest.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
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 d948990d69..829fd2dbf0 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
@@ -1347,8 +1347,7 @@ public abstract class ConsumerCoordinatorTest {
int generationId = 42;
String memberId = "consumer-42";
- Timer pollTimer = time.timer(100L);
- time.sleep(150);
+ Timer pollTimer = time.timer(0L);
boolean res = coordinator.onJoinPrepare(pollTimer, generationId,
memberId);
assertFalse(res);