[kafka] branch trunk updated: MINOR: remove unnecessary placeholder from WorkerSourceTask#recordSent (#10659)

[tombentley]

This is an automated email from the ASF dual-hosted git repository.

tombentley 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 8a574ad  MINOR: remove unnecessary placeholder from 
WorkerSourceTask#recordSent (#10659)
8a574ad is described below

commit 8a574adcae5111f1795f52d638d43fac382fd547
Author: Chia-Ping Tsai <chia7...@gmail.com>
AuthorDate: Mon May 10 17:22:26 2021 +0800

    MINOR: remove unnecessary placeholder from WorkerSourceTask#recordSent 
(#10659)
    
    Reviewers: Tom Bentley <tbent...@redhat.com>
---
 .../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 5a877ba..c66e0fc 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
@@ -475,7 +475,7 @@ class WorkerSourceTask extends WorkerTask {
             removed = outstandingMessagesBacklog.remove(record);
         // But if neither one had it, something is very wrong
         if (removed == null) {
-            log.error("{} CRITICAL Saw callback for record from topic {} 
partition {} that was not present in the outstanding message set: {}", this, 
record.topic(), record.partition());
+            log.error("{} CRITICAL Saw callback for record from topic {} 
partition {} that was not present in the outstanding message set", this, 
record.topic(), record.partition());
         } else if (flushing && outstandingMessages.isEmpty()) {
             // flush thread may be waiting on the outstanding messages to clear
             this.notifyAll();