kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch 2.0 updated: HOTFIX: Fix compilation error in ConsumerCoordinatorTest
Date Wed, 08 Aug 2018 22:52:54 GMT
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 <jason@confluent.io>
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<>();


Mime
View raw message