Repository: kafka Updated Branches: refs/heads/trunk c46cc4802 -> da7095f36
KAFKA 3656: Remove logging outstanding messages when producer flush fails Author: Liquan Pei <[email protected]> Reviewers: Ewen Cheslack-Postava <[email protected]> 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 <[email protected]> Authored: Wed May 4 16:08:08 2016 -0700 Committer: Ewen Cheslack-Postava <[email protected]> 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; }
