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 2021/04/13 14:26:15 UTC
[nifi] branch main updated: NIFI-8412: This closes #4993. Use
proper log messages in PublishKafka(Record) processors incase of 'Rollback
on Failure'
This is an automated email from the ASF dual-hosted git repository.
joewitt 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 7d5903c NIFI-8412: This closes #4993. Use proper log messages in PublishKafka(Record) processors incase of 'Rollback on Failure'
7d5903c is described below
commit 7d5903c3233c50f6a8f237c528689958f497092b
Author: Mohammed Nadeem <na...@gmail.com>
AuthorDate: Tue Apr 13 01:41:32 2021 +0530
NIFI-8412: This closes #4993. Use proper log messages in PublishKafka(Record) processors
incase of 'Rollback on Failure'
Signed-off-by: Joe Witt <jo...@apache.org>
---
.../apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_2_0.java | 4 ++--
.../org/apache/nifi/processors/kafka/pubsub/PublishKafka_2_0.java | 4 ++--
.../apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_2_6.java | 4 ++--
.../org/apache/nifi/processors/kafka/pubsub/PublishKafka_2_6.java | 4 ++--
4 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_2_0.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_2_0.java
index d3f9485..72004e6 100644
--- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_2_0.java
+++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_2_0.java
@@ -506,7 +506,7 @@ public class PublishKafkaRecord_2_0 extends AbstractProcessor {
final PublishResult publishResult = lease.complete();
if (publishResult.isFailure()) {
- getLogger().info("Failed to send FlowFile to kafka; transferring to failure");
+ getLogger().info("Failed to send FlowFile to kafka; transferring to specified failure strategy");
failureStrategy.routeFlowFiles(session, flowFiles);
return;
}
@@ -526,7 +526,7 @@ public class PublishKafkaRecord_2_0 extends AbstractProcessor {
}
} catch (final ProducerFencedException | OutOfOrderSequenceException | AuthorizationException e) {
lease.poison();
- getLogger().error("Failed to send messages to Kafka; will yield Processor and transfer FlowFiles to failure");
+ getLogger().error("Failed to send messages to Kafka; will yield Processor and transfer FlowFiles to specified failure strategy");
failureStrategy.routeFlowFiles(session, flowFiles);
context.yield();
}
diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_2_0.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_2_0.java
index 6b4b0a2..2f06a97 100644
--- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_2_0.java
+++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_2_0.java
@@ -465,7 +465,7 @@ public class PublishKafka_2_0 extends AbstractProcessor {
final PublishResult publishResult = lease.complete();
if (publishResult.isFailure()) {
- getLogger().info("Failed to send FlowFile to kafka; transferring to failure");
+ getLogger().info("Failed to send FlowFile to kafka; transferring to specified failure strategy");
failureStrategy.routeFlowFiles(session, flowFiles);
return;
}
@@ -485,7 +485,7 @@ public class PublishKafka_2_0 extends AbstractProcessor {
}
} catch (final ProducerFencedException | OutOfOrderSequenceException | AuthorizationException e) {
lease.poison();
- getLogger().error("Failed to send messages to Kafka; will yield Processor and transfer FlowFiles to failure");
+ getLogger().error("Failed to send messages to Kafka; will yield Processor and transfer FlowFiles to specified failure strategy");
failureStrategy.routeFlowFiles(session, flowFiles);
context.yield();
}
diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_2_6.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_2_6.java
index 2400416..863440e 100644
--- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_2_6.java
+++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_2_6.java
@@ -506,7 +506,7 @@ public class PublishKafkaRecord_2_6 extends AbstractProcessor {
final PublishResult publishResult = lease.complete();
if (publishResult.isFailure()) {
- getLogger().info("Failed to send FlowFile to kafka; transferring to failure");
+ getLogger().info("Failed to send FlowFile to kafka; transferring to specified failure strategy");
failureStrategy.routeFlowFiles(session, flowFiles);
return;
}
@@ -526,7 +526,7 @@ public class PublishKafkaRecord_2_6 extends AbstractProcessor {
}
} catch (final ProducerFencedException | OutOfOrderSequenceException | AuthorizationException e) {
lease.poison();
- getLogger().error("Failed to send messages to Kafka; will yield Processor and transfer FlowFiles to failure");
+ getLogger().error("Failed to send messages to Kafka; will yield Processor and transfer FlowFiles to specified failure strategy");
failureStrategy.routeFlowFiles(session, flowFiles);
context.yield();
}
diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_2_6.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_2_6.java
index 07602a3..66c1dcb 100644
--- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_2_6.java
+++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_2_6.java
@@ -463,7 +463,7 @@ public class PublishKafka_2_6 extends AbstractProcessor {
final PublishResult publishResult = lease.complete();
if (publishResult.isFailure()) {
- getLogger().info("Failed to send FlowFile to kafka; transferring to failure");
+ getLogger().info("Failed to send FlowFile to kafka; transferring to specified failure strategy");
failureStrategy.routeFlowFiles(session, flowFiles);
return;
}
@@ -483,7 +483,7 @@ public class PublishKafka_2_6 extends AbstractProcessor {
}
} catch (final ProducerFencedException | OutOfOrderSequenceException | AuthorizationException e) {
lease.poison();
- getLogger().error("Failed to send messages to Kafka; will yield Processor and transfer FlowFiles to failure");
+ getLogger().error("Failed to send messages to Kafka; will yield Processor and transfer FlowFiles to specified failure strategy");
failureStrategy.routeFlowFiles(session, flowFiles);
context.yield();
}