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)