kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jkr...@apache.org
Subject git commit: TRIVIAL: Fix spurious logging in console consumer.
Date Thu, 06 Mar 2014 16:26:50 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 4524f384d -> 6319f26e6


TRIVIAL: Fix spurious logging in console consumer.


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/6319f26e
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/6319f26e
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/6319f26e

Branch: refs/heads/trunk
Commit: 6319f26e6f47350f1e7926dea153ed848f464d2e
Parents: 4524f38
Author: Jay Kreps <jay.kreps@gmail.com>
Authored: Thu Mar 6 08:26:12 2014 -0800
Committer: Jay Kreps <jay.kreps@gmail.com>
Committed: Thu Mar 6 08:26:12 2014 -0800

----------------------------------------------------------------------
 core/src/main/scala/kafka/consumer/SimpleConsumer.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/6319f26e/core/src/main/scala/kafka/consumer/SimpleConsumer.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/consumer/SimpleConsumer.scala b/core/src/main/scala/kafka/consumer/SimpleConsumer.scala
index 098d6e4..fa7caa7 100644
--- a/core/src/main/scala/kafka/consumer/SimpleConsumer.scala
+++ b/core/src/main/scala/kafka/consumer/SimpleConsumer.scala
@@ -71,7 +71,7 @@ class SimpleConsumer(val host: String,
         response = blockingChannel.receive()
       } catch {
         case e : Throwable =>
-          warn("Reconnect due to socket error: %s".format(e.getMessage))
+          info("Reconnect due to socket error: %s".format(e.getMessage))
           // retry once
           try {
             reconnect()


Mime
View raw message