Yes https://en.m.wikipedia.org/wiki/Syslog ... View more

@MattWho you can find some examples of those Python processors here: nifi/nifi-nar-bundles/nifi-py4j-bundle/nifi-python-test-extensions/src/main/resources/extensions at main · apache/nifi · GitHub ... View more

A gotcha, you can do what you already do in your JOLT and use & instead of using 1 ... View more

You don't have to put it back into an array [] if you don't want. ... View more

@steven-matison actually commented on another post NiFi 2.0 and I was just starting to read up on it...glad you got a head start on this @SAMSAL  Don't recall where but I did see Java 21 was the minimum requirement. Also, could be Jython is gone because of the "Native" support @steven-matison mentioned in that other post. Release Notes - Apache NiFi - Apache Software Foundation New Features of 2.0.0-M1 Initial version of native Python API for Processors Stateless Execution mode for Process Groups Flow Analysis Rules API Kubernetes-based Leader Election and State Management extensions Python-based Processors for interacting with ChatGPT and Vector Databases ListenOTLP Processor for collecting OpenTelemetry ListenSlack and ConsumeSlack Processors for handling messages from Slack EncryptContentAge and DecryptContentAge Processors supporting age-encryption.org specification Schema Registry Services for Amazon Glue and Apicurio Parameter Provider for 1Password Vault YamlTreeReader for YAML as Records PackageFlowFile Processor for writing file streams and attributes as FlowFile Version 3 Migrated from H2 Database Engine to JetBrains Xodus for storing Flow Configuration History Now I want to go and try the shiny new toy...   ... View more

Did you try what the error says? Possible solutions: scan(org.springframework.data.redis.core.KeyScanOptions) ... View more

Your original example had everything at +0000 but the error has +0700 so perhaps change the pattern to  yyyy-MM-dd'T'HH:mm:ssZ ... View more

Yes, the regular expression it's asking for is that of the attribute containing the value you want... It's not asking for the value. Since you want the value of the attribute kafka.topic (name/key) then this is what the regular expression you need to match. Have you tried just putting what I previously recommended "kafka\.topic"? ... View more

The address you're trying to hit is "localhost". By any chance are you running ES in a Docker container on your machine? If so, have you exposed that port so that systems outside your own can access it? If you have, try changing localhost to your machines IP address in your NiFi ES processor config.   ... View more

The error tells you it needs to be a regular expression matching the attribute you wish to send so if it's kafka.topic it could be that literally or more accurately would be kafka\.topic ... View more