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);
 

Reply via email to