[jira] [Created] (NIFI-8404) Support "Rollback on Failure" for PublishKafka(Record) processors

["Mark Payne (Jira)" <ji...@apache.org>]

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)