[
https://issues.apache.org/jira/browse/NIFI-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468707#comment-17468707
]
Carsten commented on NIFI-8165:
-------------------------------
I was running into this issue and created a PR for that:
[https://github.com/apache/nifi/pull/5597]
This supports:
- simple flat payload property (as today - for backward compatibility)
- record path into the payload
- EL expression allowing flow file attribute references, eg `${kafka.key}`
> Add record path support to PublishKafkaRecord processor
> -------------------------------------------------------
>
> Key: NIFI-8165
> URL: https://issues.apache.org/jira/browse/NIFI-8165
> Project: Apache NiFi
> Issue Type: New Feature
> Components: Extensions
> Affects Versions: 1.11.4
> Reporter: Dave Lowe
> Priority: Major
>
> 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.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
