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 <[email protected]> Reviewers: Guozhang Wang Closes #593 from benstopford/small-patches (cherry picked from commit 09b43beb1d0aabb2776da2a5790752992ef617f7) Signed-off-by: Guozhang Wang <[email protected]> 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 <[email protected]> Authored: Fri Nov 27 12:13:59 2015 -0800 Committer: Guozhang Wang <[email protected]> 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)
