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)

Reply via email to