[
https://issues.apache.org/jira/browse/NIFI-7853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208088#comment-17208088
]
Mark Payne commented on NIFI-7853:
----------------------------------
[~mike.thomsen] it does allow for a comma-separated list, or a regex to define
which topics. But each outbound FlowFile contains Records that belong to one
specific topic. So if you configured it to listen to two Topics, A and B, one
FlowFile would be created for Records from Topic A, and a different FlowFile
would be created for Records from Topic B.
> 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)
