fix(topic): topic - skip-consumer-group is not respected

close #372
tchiotludo · Aug 28, 2020 · 506afe1 · 506afe1
1 parent 8c908c9
commit 506afe1
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/main/java/org/akhq/controllers/TopicController.java b/src/main/java/org/akhq/controllers/TopicController.java
@@ -95,7 +95,8 @@ public ResultPagedList<Topic> list(
             cluster,
             pagination,
             show.orElse(TopicRepository.TopicListView.valueOf(defaultView)),
-            search
+            search,
+            skipConsumerGroups
         ));
     }
 
@@ -198,7 +199,7 @@ public List<Partition> partitions(String cluster, String topicName) throws Execu
     @Get("api/{cluster}/topic/{topicName}/groups")
     @Operation(tags = {"topic"}, summary = "List all consumer groups from a topic")
     public List<ConsumerGroup> groups(String cluster, String topicName) throws ExecutionException, InterruptedException {
-        return this.topicRepository.findByName(cluster, topicName, false).getConsumerGroups();
+        return this.topicRepository.findByName(cluster, topicName, skipConsumerGroups).getConsumerGroups();
     }
 
     @Get("api/{cluster}/topic/{topicName}/configs")