Peter Turcsanyi created NIFI-8414:
-------------------------------------
Summary: Fix error handling of flowfiles in PublishKafka
Key: NIFI-8414
URL: https://issues.apache.org/jira/browse/NIFI-8414
Project: Apache NiFi
Issue Type: Bug
Components: Extensions
Reporter: Peter Turcsanyi
If multiple FFs are being processed in one onTrigger() call and one of them
fails (eg. due to exceeding the Max Request Size configured on the processor),
then the FFs already sent to Kafka will not be rolled backed, on the other hand
they all will go to failure in NiFi.
Expected behaviour:
* if “Use Transactions” = false, then the FFs already successfully sent to
Kafka should be sent to success in NiFi
* if “Use Transactions” = true, then the Kafka transaction should be rolled
back and the NiFi session too
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
