remove a debug message

maiha · Dec 22, 2015 · 06f17c9 · 06f17c9
1 parent 1c44fde
commit 06f17c9
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/src/main/scala/sc/ala/kafka/utils/KafkaUtils.scala b/src/main/scala/sc/ala/kafka/utils/KafkaUtils.scala
@@ -36,7 +36,6 @@ abstract class KafkaUtils extends Api {
   def leaderBrokers(topic: String): Map[Int, Broker] = {
     val resolve = brokers.groupBy(_.id).map{ case (k, list) => (k, list.head) }
     try {
-      println(s"ERROR: topic=$topic, leaders=${leaders(topic)}".red)
       leaders(topic).filter(_._2.isDefined).mapValues(_.map(resolve).get)
     } catch {
       case err: java.util.NoSuchElementException =>