Mark Payne created NIFI-7853:
--------------------------------
Summary: 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
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)
