From 2c9a15045eaac519c7a8dd20208e95a2bfccf76a Mon Sep 17 00:00:00 2001 From: Boyang Chen Date: Tue, 18 Jun 2019 13:15:04 -0700 Subject: [PATCH] MINOR: fix consumer group failure message typo (#6962) Reviewers: John Roesler , Guozhang Wang --- .../unit/kafka/admin/DeleteConsumerGroupsTest.scala | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/core/src/test/scala/unit/kafka/admin/DeleteConsumerGroupsTest.scala b/core/src/test/scala/unit/kafka/admin/DeleteConsumerGroupsTest.scala index 29c291517eb..769f33adabf 100644 --- a/core/src/test/scala/unit/kafka/admin/DeleteConsumerGroupsTest.scala +++ b/core/src/test/scala/unit/kafka/admin/DeleteConsumerGroupsTest.scala @@ -114,7 +114,7 @@ class DeleteConsumerGroupsTest extends ConsumerGroupCommandTest { TestUtils.waitUntilTrue(() => { service.collectGroupState(group).state == "Empty" - }, "The group did become empty as expected.", maxRetries = 3) + }, "The group did not become empty as expected.", maxRetries = 3) val output = TestUtils.grabConsoleOutput(service.deleteGroups()) assertTrue(s"The consumer group could not be deleted as expected", @@ -145,7 +145,7 @@ class DeleteConsumerGroupsTest extends ConsumerGroupCommandTest { TestUtils.waitUntilTrue(() => { groups.keySet.forall(groupId => service.collectGroupState(groupId).state == "Empty") - }, "The group did become empty as expected.", maxRetries = 3) + }, "The group did not become empty as expected.", maxRetries = 3) val output = TestUtils.grabConsoleOutput(service.deleteGroups()).trim val expectedGroupsForDeletion = groups.keySet @@ -175,7 +175,7 @@ class DeleteConsumerGroupsTest extends ConsumerGroupCommandTest { TestUtils.waitUntilTrue(() => { service.collectGroupState(group).state == "Empty" - }, "The group did become empty as expected.", maxRetries = 3) + }, "The group did not become empty as expected.", maxRetries = 3) val result = service.deleteGroups() assertTrue(s"The consumer group could not be deleted as expected", @@ -200,7 +200,7 @@ class DeleteConsumerGroupsTest extends ConsumerGroupCommandTest { TestUtils.waitUntilTrue(() => { service.collectGroupState(group).state == "Empty" - }, "The group did become empty as expected.", maxRetries = 3) + }, "The group did not become empty as expected.", maxRetries = 3) val service2 = getConsumerGroupService(cgcArgs ++ Array("--group", missingGroup)) val output = TestUtils.grabConsoleOutput(service2.deleteGroups()) @@ -227,7 +227,7 @@ class DeleteConsumerGroupsTest extends ConsumerGroupCommandTest { TestUtils.waitUntilTrue(() => { service.collectGroupState(group).state == "Empty" - }, "The group did become empty as expected.", maxRetries = 3) + }, "The group did not become empty as expected.", maxRetries = 3) val service2 = getConsumerGroupService(cgcArgs ++ Array("--group", missingGroup)) val result = service2.deleteGroups()