[
https://issues.apache.org/jira/browse/NIFI-11840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746595#comment-17746595
]
ASF subversion and git services commented on NIFI-11840:
--------------------------------------------------------
Commit 5cad5838c5b069e21596404a8f4d80c1e51a2e2b in nifi's branch
refs/heads/main from Paul Grey
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=5cad5838c5 ]
NIFI-11840 Add Kafka Partition and Topic Attributes before handoff to
RecordReader
This closes #7510
Signed-off-by: David Handermann <[email protected]>
> 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
> Priority: Minor
> Time Spent: 20m
> Remaining Estimate: 0h
>
> 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)
