fixed error message reporting (apache#5979)

davyam · Apr 21, 2022 · 28c7583 · 28c7583
1 parent aeaec17
commit 28c7583
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...cessors/src/main/java/org/apache/nifi/processors/kafka/pubsub/InFlightMessageTracker.java b/...cessors/src/main/java/org/apache/nifi/processors/kafka/pubsub/InFlightMessageTracker.java
@@ -70,7 +70,7 @@ public int getSentCount(final FlowFile flowFile) {
 
     public void fail(final FlowFile flowFile, final Exception exception) {
         failures.putIfAbsent(flowFile, exception);
-        logger.error("Failed to send " + flowFile + " to Kafka", exception);
+        logger.error("Failed to send {} to Kafka", flowFile, exception);
 
         synchronized (progressMutex) {
             progressMutex.notify();