kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch 1.0 updated: MINOR: add exception.toString for error log formatting (#5279)
Date Sat, 23 Jun 2018 00:25:33 GMT
This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/1.0 by this push:
     new ffa4738  MINOR: add exception.toString for error log formatting (#5279)
ffa4738 is described below

commit ffa4738a16452e807cf84c10cc13eb030fba8c6b
Author: Bill Bejeck <bbejeck@gmail.com>
AuthorDate: Fri Jun 22 20:25:29 2018 -0400

    MINOR: add exception.toString for error log formatting (#5279)
    
    Reviewers: Guozhang Wang <wangguoz@gmail.com>
---
 .../apache/kafka/streams/processor/internals/RecordCollectorImpl.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 4eec2d5..a3aea1c 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
@@ -110,7 +110,7 @@ public class RecordCollectorImpl implements RecordCollector {
                             if (sendException == null) {
                                 log.error("Error sending record (key {} value {} timestamp
{}) to topic {} due to {}; " +
                                                 "No more records will be sent and no more
offsets will be recorded for this task.",
-                                        key, value, timestamp, topic, exception);
+                                        key, value, timestamp, topic, exception.toString());
                                 if (exception instanceof ProducerFencedException) {
                                     sendException = new ProducerFencedException(String.format("%sAbort
sending since producer got fenced with a previous record (key %s value %s timestamp %d) to
topic %s, error message: %s",
                                             logPrefix, key, value, timestamp, topic, exception.getMessage()));


Mime
View raw message