[nifi] branch main updated: fixed error message reporting (#5979)

[markap14]

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

markap14 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/main by this push:
     new 28c7583bdb fixed error message reporting (#5979)
28c7583bdb is described below

commit 28c7583bdb70055ea19767abe29bce5ea2f63b66
Author: Ravinarayan Singh <ravisingh...@gmail.com>
AuthorDate: Thu Apr 21 08:12:02 2022 -0500

    fixed error message reporting (#5979)
---
 .../org/apache/nifi/processors/kafka/pubsub/InFlightMessageTracker.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/InFlightMessageTracker.java
 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/InFlightMessageTracker.java
index 3ec3d1c53f..f93d315db7 100644
--- 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/InFlightMessageTracker.java
+++ 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/InFlightMessageTracker.java
@@ -70,7 +70,7 @@ public class InFlightMessageTracker {
 
     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();