Mark Payne created NIFI-8661:
--------------------------------

             Summary: Update Record Reader/Writer lookup services to not 
require specific attributes exist
                 Key: NIFI-8661
                 URL: https://issues.apache.org/jira/browse/NIFI-8661
             Project: Apache NiFi
          Issue Type: Improvement
          Components: Extensions
            Reporter: Mark Payne
            Assignee: Mark Payne


NIFI-5829 introduced a ReaderLookup service and a RecordSetWriterLookup 
service. However, these services make the assumption that the reader/writer to 
use exists on an attribute of the flowfile such asĀ {{recordreader.name}}. This 
means that these services are not applicable for many situations, especially 
for source processors.

A more convenient way would be to just add a property to these services 
indicating the name of the service to use, instead of expecting that an 
attribute with that name exists. We can set the default value of the property 
to `${recordreader.name}` etc. in order to maintain backward compatibility.

But this gives us the flexibility, for example, to use this in 
ConsumeKafkaRecord where kafka message headers are available in Expression 
Language and also gives us the ability to use a parameter for specifying the 
data format to use.



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

Reply via email to