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