I think the easiest way to do the conditional fetch would be to use ConsumeKafka (or something equivalent for this use case like ListenHttp) and FetchFile.
On Mon, Feb 5, 2024 at 4:23 PM Dan S <[email protected]> wrote: > I have a requirement to load Json Schemas into the > StandardJsonSchemaRegistry from the file system for use in validating JSON > with the ValidateJson processor. I am trying to use the NIFI Rest API to > update the StandardJsonSchemaRegistry. I am able to stop the ValidateJson > processor and disable the StandardJsonSchemaRegistry using the NIFI Rest > API. I do not know though how I can indicate either to GetFile or ListFile > (to allow for retrieval of the JSON schemas) that ValidateJson has been > stopped and StandardJsonSchemaRegistry has been disabled since both of > these processors do not allow for an incoming relationship. How can I do > this and if this is not possible how can I accomplish this? >
