[NIFI-8412] Use proper log messages in PublishKafka(Record) processors in case of "Rollback on Failure"

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.14.0
• Component/s: Extensions
• Assignee: Nadeem
• Reporter: Peter Turcsanyi
• Created: 09/Apr/21 16:02
• Updated: 13/Apr/21 14:26
• Resolved: 13/Apr/21 14:26

Description

The following log message is not correct any more if the failure strategy is Rollback (NIFI-8404):

getLogger().info("Failed to send FlowFile to kafka; transferring to failure");
failureStrategy.routeFlowFiles(session, flowFiles);

Issue Links

• relates to: NIFI-8404 Support "Rollback on Failure" for PublishKafka(Record) processors
• links to: GitHub Pull Request #4993