Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

change log level to info for ITKafkaTest

This commit is contained in:
Bingkun Guo 2016-01-11 15:34:37 -06:00
parent 8d1686039a
commit 36ca5b1703
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
integration-tests/src/test/java/io/druid/tests/indexer/ITKafkaTest.java
View File

@ -181,7 +181,6 @@ public class ITKafkaTest extends AbstractIndexerTest
// send data to kafka // send data to kafka
while (dt.compareTo(dtStop) < 0) { // as long as we're within the time span 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++; num_events++;
added += num_events; added += num_events;
// construct the event to send // construct the event to send
@ -189,7 +188,7 @@ public class ITKafkaTest extends AbstractIndexerTest
event_template, event_template,
event_fmt.print(dt), num_events, 0, num_events event_fmt.print(dt), num_events, 0, num_events
); );
LOG.debug("event: [%s]", event); LOG.info("sending event: [%s]", event);
try { try {
// Send event to kafka // Send event to kafka
KeyedMessage<String, String> message = new KeyedMessage<String, String>(TOPIC_NAME, event); KeyedMessage<String, String> message = new KeyedMessage<String, String>(TOPIC_NAME, event);