Hello. I'm trying to create a fileType filtering system under Nifi. My team plans on kafka ingesting various types of files and processing their metadata for various purposes. For now, I'm simply to fully understand how route files based on their end type (e.g. .txt, .tif) from kafka to the appropriate custom extractors that we're developing. Given my unfamiliarity with NifFi processor coding, I'm not positive as to how to best accomplish this task. As a Java programmer, I'd imagine creating an abstract class, then extending it with concrete versions based on what file type we need. For example: fileName.endsWith(".xml") -> send to appropriate custome extractor, etc. Based on my research thus far, I suspect that the onRouteAttribute processor will be core to this, but I'm not 100% sure, and we lack a NiFi guru.. A just need a point in the right direction on how to start designing this pipeline filter within NiFi. Responses are appreciated. P.S. If any can point out templates that may help, it's further appreciated. ... View more