This is an automated email from the ASF dual-hosted git repository.

jgus pushed a commit to branch 2.0
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.0 by this push:
     new 2c120be  HOTFIX: Fix compilation error in ConsumerCoordinatorTest
2c120be is described below

commit 2c120bef5bb09ca654b3f57dfce4f98c11622821
Author: Jason Gustafson <[email protected]>
AuthorDate: Wed Aug 8 15:52:42 2018 -0700

    HOTFIX: Fix compilation error in ConsumerCoordinatorTest
---
 .../kafka/clients/consumer/internals/ConsumerCoordinatorTest.java       | 2 +-
 1 file changed, 1 insertion(+), 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 8d5564e..7f7e0f2 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
@@ -1771,7 +1771,7 @@ public class ConsumerCoordinatorTest {
 
         // Assign two partitions to trigger a metric change that can lead to 
ConcurrentModificationException
         client.prepareResponse(groupCoordinatorResponse(node, Errors.NONE));
-        coordinator.ensureCoordinatorReady(time.timer(Long.MAX_VALUE));
+        coordinator.ensureCoordinatorReady(Long.MAX_VALUE);
 
         // Change the assignment several times to increase likelihood of 
concurrent updates
         Set<TopicPartition> partitions = new HashSet<>();

Reply via email to