kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated: MINOR: Remove redundant placeholder in log message (#7016)
Date Wed, 03 Jul 2019 18:23:36 GMT
This is an automated email from the ASF dual-hosted git repository.

jgus 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 0b40d27  MINOR: Remove redundant placeholder in log message (#7016)
0b40d27 is described below

commit 0b40d276477e6f405c6c163cee7d8b45c849eef7
Author: Cheng Pan <379377944@qq.com>
AuthorDate: Wed Jul 3 13:23:23 2019 -0500

    MINOR: Remove redundant placeholder in log message (#7016)
    
    Reviewers: Jason Gustafson <jason@confluent.io>
---
 .../main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
index bb1ad77..9ab4f41 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
@@ -327,7 +327,7 @@ class WorkerSourceTask extends WorkerTask {
                                     // timeouts, callbacks with exceptions should never be
invoked in practice. If the
                                     // user overrode these settings, the best we can do is
notify them of the failure via
                                     // logging.
-                                    log.error("{} failed to send record to {}: {}", WorkerSourceTask.this,
topic, e);
+                                    log.error("{} failed to send record to {}:", WorkerSourceTask.this,
topic, e);
                                     log.debug("{} Failed record: {}", WorkerSourceTask.this,
preTransformRecord);
                                 } else {
                                     log.trace("{} Wrote record successfully: topic {} partition
{} offset {}",


Mime
View raw message