Mark Payne created NIFI-8404: -------------------------------- Summary: Support "Rollback on Failure" for PublishKafka(Record) processors Key: NIFI-8404 URL: https://issues.apache.org/jira/browse/NIFI-8404 Project: Apache NiFi Issue Type: Improvement Components: Extensions Reporter: Mark Payne Assignee: Mark Payne
When the PublishKafka(Record) processors encounter a failure, they route the FlowFiles to the 'failure' relationship. That's usually what we want. But in some cases, we want to be able to rollback on failure. This goes hand-in-hand with the recent feature that was added to allow static assignment of Kafka Partitions to NiFi nodes. That feature ensures that even in a NiFi cluster, we won't have data out-of-order (assuming proper configuration) by sending data from the same partition to multiple NiFi nodes. -- This message was sent by Atlassian Jira (v8.3.4#803005)