From 02b05b1a8b19368c9ec4ff2bb771faa3287cf50d Mon Sep 17 00:00:00 2001
From: Philipp Schirmer <philipp.schirmer@bakdata.com>
Date: Mon, 6 Jan 2025 18:22:43 +0100
Subject: [PATCH] Debug

---
 .../main/java/com/bakdata/kafka/util/ConsumerGroupClient.java | 4 ----
 1 file changed, 4 deletions(-)

diff --git a/streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/ConsumerGroupClient.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/ConsumerGroupClient.java
index 844777aa..0d053d70 100644
--- a/streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/ConsumerGroupClient.java
+++ b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/ConsumerGroupClient.java
@@ -31,7 +31,6 @@
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
-import java.util.stream.Collectors;
 import lombok.NonNull;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -93,9 +92,6 @@ public void close() {
      */
     public boolean exists(final String groupName) {
         final Collection<ConsumerGroupListing> consumerGroups = this.listGroups();
-        log.info("Found consumer groups: {}", consumerGroups.stream()
-                .map(ConsumerGroupListing::groupId)
-                .collect(Collectors.joining(", ")));
         return consumerGroups.stream()
                 .anyMatch(c -> c.groupId().equals(groupName));
     }