Skip to content

Commit

Permalink
SKYEDEN-3271 | remove println
Browse files Browse the repository at this point in the history
  • Loading branch information
MarcinBobinski committed Dec 2, 2024
1 parent f308826 commit e6039cf
Showing 1 changed file with 0 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand Down

0 comments on commit e6039cf

Please sign in to comment.