You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2019/06/18 20:15:24 UTC
[kafka] branch trunk updated: MINOR: fix consumer group failure
message typo (#6962)
This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 2c9a150 MINOR: fix consumer group failure message typo (#6962)
2c9a150 is described below
commit 2c9a15045eaac519c7a8dd20208e95a2bfccf76a
Author: Boyang Chen <bo...@confluent.io>
AuthorDate: Tue Jun 18 13:15:04 2019 -0700
MINOR: fix consumer group failure message typo (#6962)
Reviewers: John Roesler <jo...@confluent.io>, Guozhang Wang <gu...@confluent.io>
---
.../test/scala/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 29c2915..769f33a 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()