diff --git a/hermes-management/src/main/java/pl/allegro/tech/hermes/management/domain/subscription/consumergroup/ConsumerGroupCleanUpTask.java b/hermes-management/src/main/java/pl/allegro/tech/hermes/management/domain/subscription/consumergroup/ConsumerGroupCleanUpTask.java index 3f5691a6c5..3b0fab93e6 100644 --- a/hermes-management/src/main/java/pl/allegro/tech/hermes/management/domain/subscription/consumergroup/ConsumerGroupCleanUpTask.java +++ b/hermes-management/src/main/java/pl/allegro/tech/hermes/management/domain/subscription/consumergroup/ConsumerGroupCleanUpTask.java @@ -39,12 +39,10 @@ public ConsumerGroupCleanUpTask( @Override public void run() { - System.out.println("[DEBUG] ConsumerGroupCleanUpTask.run() called"); consumerGroupToDeleteRepositoriesByDatacenter.values().stream() .flatMap(repository -> repository.getAllConsumerGroupsToDelete().stream()) .filter(this::shouldConsumerGroupDeletionTaskBeProcessed) .forEach(this::tryToDeleteConsumerGroup); - System.out.println("[DEBUG] ConsumerGroupCleanUpTask.run() finished"); } private void tryToDeleteConsumerGroup(ConsumerGroupToDelete consumerGroupToDelete) {