[kafka] branch 1.0 updated: MINOR: add exception.toString for error log formatting (#5279)

[gu...@apache.org]

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 <bb...@gmail.com>
AuthorDate: Fri Jun 22 20:25:29 2018 -0400

    MINOR: add exception.toString for error log formatting (#5279)
    
    Reviewers: Guozhang Wang <wa...@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()));