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 <[email protected]>
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 <[email protected]>
---
.../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();
}
