Debug

bakdata · Jan 6, 2025 · 02b05b1 · 02b05b1
1 parent 6962130
commit 02b05b1
Showing 1 changed file with 0 additions and 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
@@ -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));
     }