You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2018/05/09 06:02:40 UTC
[kafka] branch trunk updated: MINOR: Fix trace logging in
ReplicaManager (#4916)
This is an automated email from the ASF dual-hosted git repository.
ijuma pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new b27e098 MINOR: Fix trace logging in ReplicaManager (#4916)
b27e098 is described below
commit b27e098a7dbcc07c6abb758de570596c74722025
Author: Colin Patrick McCabe <co...@cmccabe.xyz>
AuthorDate: Tue May 8 23:02:33 2018 -0700
MINOR: Fix trace logging in ReplicaManager (#4916)
Reviewers: Ismael Juma <is...@juma.me.uk>
---
core/src/main/scala/kafka/server/ReplicaManager.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala b/core/src/main/scala/kafka/server/ReplicaManager.scala
index da50117..85c66a5 100644
--- a/core/src/main/scala/kafka/server/ReplicaManager.scala
+++ b/core/src/main/scala/kafka/server/ReplicaManager.scala
@@ -754,8 +754,8 @@ class ReplicaManager(val config: KafkaConfig,
brokerTopicStats.topicStats(topicPartition.topic).messagesInRate.mark(numAppendedMessages)
brokerTopicStats.allTopicsStats.messagesInRate.mark(numAppendedMessages)
- trace("%d bytes written to log %s-%d beginning at offset %d and ending at offset %d"
- .format(records.sizeInBytes, topicPartition.topic, topicPartition.partition, info.firstOffset, info.lastOffset))
+ trace(s"${records.sizeInBytes} written to log ${topicPartition} beginning at offset " +
+ s"${info.firstOffset.getOrElse(-1)} and ending at offset ${info.lastOffset}")
(topicPartition, LogAppendResult(info))
} catch {
// NOTE: Failed produce requests metric is not incremented for known exceptions
--
To stop receiving notification emails like this one, please contact
ijuma@apache.org.