[ 
https://issues.apache.org/jira/browse/NIFI-7853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17206677#comment-17206677
 ] 

Mike Thomsen commented on NIFI-7853:
------------------------------------

[~markap14] the topic property supports a comma-separated list. Any ideas on 
that would work here?

> ConsumeKafkaRecord* processors should provide Kafka topic/partition to 
> RecordReaderFactory
> ------------------------------------------------------------------------------------------
>
>                 Key: NIFI-7853
>                 URL: https://issues.apache.org/jira/browse/NIFI-7853
>             Project: Apache NiFi
>          Issue Type: Bug
>          Components: Extensions
>            Reporter: Mark Payne
>            Priority: Major
>
> When using the ConsumeKafkaRecord processors, the Record Reader is created 
> using several key/value pairs that are extracted from Kafka message headers. 
> This map should also contain the Kafka topic/partition, so that these can be 
> provided to the Record Reader Factory as well. These may be relevant for 
> determining the Schema to use, for instance.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to