From e8710e8fe4d29cce6381456cfbb389000d25ce0f Mon Sep 17 00:00:00 2001 From: Gwen Shapira Date: Fri, 22 Feb 2019 11:17:46 -0800 Subject: [PATCH] KAFKA-7937: Fix Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup --- .../scala/unit/kafka/admin/ResetConsumerGroupOffsetTest.scala | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/core/src/test/scala/unit/kafka/admin/ResetConsumerGroupOffsetTest.scala b/core/src/test/scala/unit/kafka/admin/ResetConsumerGroupOffsetTest.scala index eaa0c853e66e9..007edd9a9730a 100644 --- a/core/src/test/scala/unit/kafka/admin/ResetConsumerGroupOffsetTest.scala +++ b/core/src/test/scala/unit/kafka/admin/ResetConsumerGroupOffsetTest.scala @@ -86,6 +86,10 @@ class ResetConsumerGroupOffsetTest extends ConsumerGroupCommandTest { val args = Array("--bootstrap-server", brokerList, "--reset-offsets", "--group", "missing.group", "--all-topics", "--to-current", "--execute") val consumerGroupCommand = getConsumerGroupService(args) + // Make sure we got a coordinator + TestUtils.waitUntilTrue(() => { + consumerGroupCommand.collectGroupState().coordinator.host() == "localhost" + }, "Can't find a coordinator.", maxRetries = 3) val resetOffsets = consumerGroupCommand.resetOffsets() assertEquals(Map.empty, resetOffsets) assertEquals(resetOffsets, committedOffsets(group = "missing.group"))