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

I you're confident the data returned is consistent and always more than 7 lines...then a quick and dirty would be a Groovy script like this. import java.nio.charset.StandardCharsets FlowFile flowFile = session.get() if(!flowFile) return flowFile = session.write(flowFile, {inputStream, outputStream -> String[] data = inputStream.readLines() data = data.drop(7) outputStream.write(data.join("\n").getBytes(StandardCharsets.UTF_8)) } as StreamCallback) session.transfer(flowFile, REL_SUCCESS) ... View more

What you posted looks like AMQP/RabbitMQ related messages. What does your Python script do and return? You might be able to build a lot of what that Python script is doing directly in NiFi so you're not having to do external calls.   ... View more