kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: KAFKA-2899: improve logging when unexpected exceptions thrown in reading local log
Date Fri, 27 Nov 2015 20:14:10 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.9.0 7d37086e5 -> 60c44801c


KAFKA-2899: improve logging when unexpected exceptions thrown in reading local log

Currently we don't log exceptions raised when reading from the local log which makes tracking
down the cause of problems a bit tricky.

Author: Ben Stopford <benstopford@gmail.com>

Reviewers: Guozhang Wang

Closes #593 from benstopford/small-patches

(cherry picked from commit 09b43beb1d0aabb2776da2a5790752992ef617f7)
Signed-off-by: Guozhang Wang <wangguoz@gmail.com>


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

Branch: refs/heads/0.9.0
Commit: 60c44801c9e3a2e730d96bb4c9065d41fdd1c1c0
Parents: 7d37086
Author: Ben Stopford <benstopford@gmail.com>
Authored: Fri Nov 27 12:13:59 2015 -0800
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Fri Nov 27 12:14:07 2015 -0800

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


http://git-wip-us.apache.org/repos/asf/kafka/blob/60c44801/core/src/main/scala/kafka/server/ReplicaManager.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala b/core/src/main/scala/kafka/server/ReplicaManager.scala
index a4553b3..7a99aad 100644
--- a/core/src/main/scala/kafka/server/ReplicaManager.scala
+++ b/core/src/main/scala/kafka/server/ReplicaManager.scala
@@ -556,7 +556,7 @@ class ReplicaManager(val config: KafkaConfig,
           case e: Throwable =>
             BrokerTopicStats.getBrokerTopicStats(topic).failedFetchRequestRate.mark()
             BrokerTopicStats.getBrokerAllTopicsStats().failedFetchRequestRate.mark()
-            error("Error processing fetch operation on partition [%s,%d] offset %d".format(topic,
partition, offset))
+            error("Error processing fetch operation on partition [%s,%d] offset %d".format(topic,
partition, offset), e)
             LogReadResult(FetchDataInfo(LogOffsetMetadata.UnknownOffsetMetadata, MessageSet.Empty),
-1L, fetchSize, false, Some(e))
         }
       (TopicAndPartition(topic, partition), partitionDataAndOffsetInfo)


Mime
View raw message