[NIFI-11840] ConsumeKafkaRecord, add Kafka record metadata attributes before handoff to RecordReader

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 2.0.0-M1, 1.23.0
• Assignee: Paul Grey
• Reporter: Paul Grey
• Created: 20/Jul/23 18:06
• Updated: 24/Jul/23 18:47
• Resolved: 24/Jul/23 18:47

Description

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

Issue Links

• links to: GitHub Pull Request #7510