KAFKA-2822: DescribeConsumerGroup now returns empty list for non-exis…

…tent group. …tent group, it used to throw IllegalArgumentException Author: Ashish Singh <[email protected]> Reviewers: Jason Gustafson, Guozhang Wang Closes apache#515 from SinghAsDev/KAFKA-2822
AllenRay · Nov 12, 2015 · 28d71ce · 28d71ce
1 parent 1408c67
commit 28d71ce
Showing 1 changed file with 1 addition and 7 deletions.
diff --git a/core/src/test/scala/integration/kafka/api/AdminClientTest.scala b/core/src/test/scala/integration/kafka/api/AdminClientTest.scala
@@ -113,12 +113,6 @@ class AdminClientTest extends IntegrationTestHarness with Logging {
   @Test
   def testDescribeConsumerGroupForNonExistentGroup() {
     val nonExistentGroup = "non" + groupId
-    try {
-      client.describeConsumerGroup(nonExistentGroup)
-      fail("Should have failed for non existent group.")
-    } catch {
-      case ex: IllegalArgumentException => // Pass
-      case _: Throwable => fail("Should have failed for non existent group with IllegalArgumentException.")
-    }
+    assertTrue("Expected empty ConsumerSummary list", client.describeConsumerGroup(nonExistentGroup).isEmpty)
   }
 }