From 77af8cf2a7fbb0ecb58b63715ee1926655d96103 Mon Sep 17 00:00:00 2001
From: Liquan Pei <liquanpei@gmail.com>
Date: Wed, 4 May 2016 10:08:37 -0700
Subject: [PATCH] Removing logging outstanding messages

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

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 602af4a533f72..fd551abd3f7b1 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 @@ public boolean commitOffsets() {
                 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;
                     }