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();