[NIFI-8165] Add record path support to PublishKafkaRecord processor

• Type: New Feature
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.11.4
• Component/s: Extensions
• Assignee: Unassigned
• Reporter: Dave Lowe
• Created: 21/Jan/21 22:54
• Updated: 20/May/22 00:14

Description

NiFi RecordPath's are not supported within the PublishKafkaRecord processor.

Users are unable to leverage RecordPaths within properties such as the message key. Without support of RecordPaths, the message key must be within the root of the record being published - which is often not the case with complex real-world workloads. In such circumstances, the record must be adjusted prior to publishing to Kafka via the UpdateRecord procoessor to copy the nested element to the root so that it can be leveraged as the message key.

Issue Links

• links to: GitHub Pull Request #5597