kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: KAFKA 3656: Remove logging outstanding messages when producer flush fails
Date Wed, 04 May 2016 23:08:20 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk c46cc4802 -> da7095f36


KAFKA 3656: Remove logging outstanding messages when producer flush fails

Author: Liquan Pei <liquanpei@gmail.com>

Reviewers: Ewen Cheslack-Postava <ewen@confluent.io>

Closes #1319 from Ishiihara/kafka-3656


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

Branch: refs/heads/trunk
Commit: da7095f3689b7a16f2b9050a8b1e5a3d6d400b12
Parents: c46cc48
Author: Liquan Pei <liquanpei@gmail.com>
Authored: Wed May 4 16:08:08 2016 -0700
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Wed May 4 16:08:08 2016 -0700

----------------------------------------------------------------------
 .../java/org/apache/kafka/connect/runtime/WorkerSourceTask.java  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/da7095f3/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
----------------------------------------------------------------------
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 602af4a..fd551ab 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
@@ -286,9 +286,7 @@ class WorkerSourceTask extends WorkerTask {
                 try {
                     long timeoutMs = timeout - time.milliseconds();
                     if (timeoutMs <= 0) {
-                        log.error(
-                                "Failed to flush {}, timed out while waiting for producer
to flush outstanding "
-                                        + "messages, {} left ({})", this, outstandingMessages.size(),
outstandingMessages);
+                        log.error("Failed to flush {}, timed out while waiting for producer
to flush outstanding {} messages", this, outstandingMessages.size());
                         finishFailedFlush();
                         return false;
                     }


Mime
View raw message