Uploaded image for project: 'Apache NiFi'
  1. Apache NiFi
  2. NIFI-8661

Update Record Reader/Writer lookup services to not require specific attributes exist

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.14.0
    • Component/s: Extensions
    • Labels:
      None

      Description

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                markap14 Mark Payne
                Reporter:
                markap14 Mark Payne
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 0.5h
                  0.5h