You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by jo...@apache.org on 2022/04/21 15:00:17 UTC
[nifi] 03/06: fixed error message reporting (#5979)
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 <ra...@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();