Paul Grey created NIFI-11840:
--------------------------------
Summary: ConsumeKafkaRecord, add Kafka record metadata attributes
before handoff to RecordReader
Key: NIFI-11840
URL: https://issues.apache.org/jira/browse/NIFI-11840
Project: Apache NiFi
Issue Type: Improvement
Reporter: Paul Grey
Assignee: Paul Grey
This adjustment would handle cases where RecordReader might want to adjust
behavior based on metadata from the incoming Kafka ConsumeRecord (for example,
topic name).
One possibility would be to move attribute set from here:
https://github.com/apache/nifi/blob/1156f4cbc57c2bac5654d6b475ddfd486cb66050/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerLease.java#L829-L830
to here:
https://github.com/apache/nifi/blob/1156f4cbc57c2bac5654d6b475ddfd486cb66050/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerLease.java#L573
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
