From commits-return-9863-archive-asf-public=cust-asf.ponee.io@kafka.apache.org Sat Jun 23 02:25:35 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 61B18180647 for ; Sat, 23 Jun 2018 02:25:35 +0200 (CEST) Received: (qmail 97919 invoked by uid 500); 23 Jun 2018 00:25:34 -0000 Mailing-List: contact commits-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list commits@kafka.apache.org Received: (qmail 97910 invoked by uid 99); 23 Jun 2018 00:25:34 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 23 Jun 2018 00:25:34 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id B0C5385140; Sat, 23 Jun 2018 00:25:33 +0000 (UTC) Date: Sat, 23 Jun 2018 00:25:33 +0000 To: "commits@kafka.apache.org" Subject: [kafka] branch 1.0 updated: MINOR: add exception.toString for error log formatting (#5279) MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <152971353283.20149.11099859455536382567@gitbox.apache.org> From: guozhang@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: kafka X-Git-Refname: refs/heads/1.0 X-Git-Reftype: branch X-Git-Oldrev: 9450a241e4fbaa29af7791fa714ac701952e01c7 X-Git-Newrev: ffa4738a16452e807cf84c10cc13eb030fba8c6b X-Git-Rev: ffa4738a16452e807cf84c10cc13eb030fba8c6b X-Git-NotificationType: ref_changed_plus_diff X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated 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 AuthorDate: Fri Jun 22 20:25:29 2018 -0400 MINOR: add exception.toString for error log formatting (#5279) Reviewers: Guozhang Wang --- .../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()));