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/trunk Commit: e37a4644209de00f265a5361b31ca63cafc895e9 Parents: 6e640e3 Author: Joel Koshy <[email protected]> Authored: Fri Apr 26 14:13:00 2013 -0700 Committer: Joel Koshy <[email protected]> Committed: Fri Apr 26 14:13:00 2013 -0700 ---------------------------------------------------------------------- core/src/main/scala/kafka/server/AbstractFetcherThread.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- 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
