From 06f17c937023fbb3e8d0896f825f48538cb652ab Mon Sep 17 00:00:00 2001
From: maiha <kazunori_nishi@dwango.co.jp>
Date: Tue, 22 Dec 2015 14:20:40 +0900
Subject: [PATCH] remove a debug message

---
 src/main/scala/sc/ala/kafka/utils/KafkaUtils.scala | 1 -
 1 file changed, 1 deletion(-)

diff --git a/src/main/scala/sc/ala/kafka/utils/KafkaUtils.scala b/src/main/scala/sc/ala/kafka/utils/KafkaUtils.scala
index e611e8d..3010f25 100644
--- 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 =>