kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: Fix warn logging in RecordCollectorImpl
Date Wed, 13 Dec 2017 03:13:44 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk b08882213 -> fe3699ce3


MINOR: Fix warn logging in RecordCollectorImpl

Fix warn log message in RecordCollectorImpl so it prints the exception message rather than
`{}`

Author: Damian Guy <damian.guy@gmail.com>

Reviewers: Matthias J. Sax <matthias@confluent.io>, Bill Bejeck <bill@confluent.io>,
GuozhangWang <wangguoz@gmail.com>

Closes #4318 from dguy/minor-logging-record-collector


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

Branch: refs/heads/trunk
Commit: fe3699ce3362c8942f96e52281a2bd0fc1bda032
Parents: b088822
Author: Damian Guy <damian.guy@gmail.com>
Authored: Tue Dec 12 19:13:39 2017 -0800
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Tue Dec 12 19:13:39 2017 -0800

----------------------------------------------------------------------
 .../kafka/streams/processor/internals/RecordCollectorImpl.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/fe3699ce/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
index 9566051..0cc2699 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
@@ -107,7 +107,7 @@ public class RecordCollectorImpl implements RecordCollector {
                     } else {
                         if (sendException == null) {
                             if (exception instanceof ProducerFencedException) {
-                                log.warn(LOG_MESSAGE, key, value, timestamp, topic, exception);
+                                log.warn(LOG_MESSAGE, key, value, timestamp, topic, exception.getMessage());
                                 sendException = new ProducerFencedException(
                                     String.format(EXCEPTION_MESSAGE,
                                                   logPrefix,


Mime
View raw message