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)