From 36ca5b170356f36774c5a8f2e48abb7d6544091f Mon Sep 17 00:00:00 2001
From: Bingkun Guo <guobingkun@yahoo-inc.com>
Date: Mon, 11 Jan 2016 15:34:37 -0600
Subject: [PATCH] change log level to info for ITKafkaTest

---
 .../src/test/java/io/druid/tests/indexer/ITKafkaTest.java      | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/integration-tests/src/test/java/io/druid/tests/indexer/ITKafkaTest.java b/integration-tests/src/test/java/io/druid/tests/indexer/ITKafkaTest.java
index 2f82cea9c1e..41cb112f693 100644
--- a/integration-tests/src/test/java/io/druid/tests/indexer/ITKafkaTest.java
+++ b/integration-tests/src/test/java/io/druid/tests/indexer/ITKafkaTest.java
@@ -181,7 +181,6 @@ public class ITKafkaTest extends AbstractIndexerTest
 
     // send data to kafka
     while (dt.compareTo(dtStop) < 0) {  // as long as we're within the time span
-      LOG.info("sending event at [%s]", event_fmt.print(dt));
       num_events++;
       added += num_events;
       // construct the event to send
@@ -189,7 +188,7 @@ public class ITKafkaTest extends AbstractIndexerTest
           event_template,
           event_fmt.print(dt), num_events, 0, num_events
       );
-      LOG.debug("event: [%s]", event);
+      LOG.info("sending event: [%s]", event);
       try {
         // Send event to kafka
         KeyedMessage<String, String> message = new KeyedMessage<String, String>(TOPIC_NAME, event);