kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jjko...@apache.org
Subject git commit: Trivial commit - warn on consumer fetch request errors.
Date Fri, 26 Apr 2013 21:13:16 GMT
Updated Branches:
  refs/heads/0.8 6e640e355 -> e37a46442


Trivial commit - warn on consumer fetch request errors.


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

Branch: refs/heads/0.8
Commit: e37a4644209de00f265a5361b31ca63cafc895e9
Parents: 6e640e3
Author: Joel Koshy <jjkoshy@gmail.com>
Authored: Fri Apr 26 14:13:00 2013 -0700
Committer: Joel Koshy <jjkoshy@gmail.com>
Committed: Fri Apr 26 14:13:00 2013 -0700

----------------------------------------------------------------------
 .../scala/kafka/server/AbstractFetcherThread.scala |    2 +-
 1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/e37a4644/core/src/main/scala/kafka/server/AbstractFetcherThread.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/server/AbstractFetcherThread.scala b/core/src/main/scala/kafka/server/AbstractFetcherThread.scala
index fed3b86..2ac7a17 100644
--- a/core/src/main/scala/kafka/server/AbstractFetcherThread.scala
+++ b/core/src/main/scala/kafka/server/AbstractFetcherThread.scala
@@ -96,7 +96,7 @@ abstract class AbstractFetcherThread(name: String, clientId: String, sourceBroke
       response = simpleConsumer.fetch(fetchRequest)
     } catch {
       case t =>
-        debug("error in fetch %s".format(fetchRequest), t)
+        warn("Error in fetch %s".format(fetchRequest), t)
         if (isRunning.get) {
           partitionMapLock synchronized {
             partitionsWithError ++= partitionMap.keys


Mime
View raw message