This is an automated email from the ASF dual-hosted git repository. joewitt pushed a commit to branch support/nifi-1.16 in repository https://gitbox.apache.org/repos/asf/nifi.git
commit bc463b0c1513a8c00324b35782d445952f74eda5 Author: Ravinarayan Singh <[email protected]> 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();
