Skip to content

Commit

Permalink
Remove debug code
Browse files Browse the repository at this point in the history
  • Loading branch information
seglo committed Oct 21, 2019
1 parent 73d6515 commit e119105
Showing 1 changed file with 1 addition and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -98,10 +98,7 @@ public void start() {

Unreliables.retryUntilTrue(30, TimeUnit.SECONDS, () -> this.brokers.stream().findFirst()
.map(this::clusterBrokers)
.filter(brokers -> {
System.out.println("Found broker str: " + brokers);
return brokers.split(",").length == this.brokersNum;
})
.filter(brokers -> brokers.split(",").length == this.brokersNum)
.isPresent());
}

Expand Down

0 comments on commit e119105

Please sign in to comment.