Debug

bakdata · Jan 6, 2025 · cdc72ad · cdc72ad
1 parent ce83a54
commit cdc72ad
Showing 1 changed file with 2 additions and 1 deletion.
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
@@ -1,7 +1,7 @@
 /*
  * MIT License
  *
- * Copyright (c) 2024 bakdata
+ * Copyright (c) 2025 bakdata
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal
@@ -92,6 +92,7 @@ public void close() {
      */
     public boolean exists(final String groupName) {
         final Collection<ConsumerGroupListing> consumerGroups = this.listGroups();
+        log.trace("Found {} consumer groups", consumerGroups.size());
         return consumerGroups.stream()
                 .anyMatch(c -> c.groupId().equals(groupName));
     }