Member since
06-14-2023
96
Posts
34
Kudos Received
9
Solutions
My Accepted Solutions
| Title | Views | Posted |
|---|---|---|
| 2827 | 11-04-2024 06:51 PM | |
| 7361 | 12-29-2023 09:36 AM | |
| 11199 | 12-28-2023 01:01 PM | |
| 2483 | 12-27-2023 12:14 PM | |
| 1501 | 12-08-2023 12:47 PM |
11-28-2023
09:40 AM
Did you try what the error says? Possible solutions: scan(org.springframework.data.redis.core.KeyScanOptions)
... View more
11-26-2023
05:54 PM
1 Kudo
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
11-24-2023
09:59 AM
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
11-24-2023
09:53 AM
1 Kudo
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
11-22-2023
11:33 AM
2 Kudos
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
11-21-2023
10:56 PM
1 Kudo
It could be NiFi only includes the core Groovy jar files and you may need to download the additional ones and add to the NiFi lib directory for the additional classes to be accessible.
... View more
11-21-2023
02:20 PM
A quick Google search shows it's possible to build a DTLS server (Listener) with Java which means it might be possible to create a custom Groovy based processor to implement it.
... View more
11-21-2023
01:56 PM
What's wrong with 1:1 relationship? If you're concerned with performance, then leveraging "Message Demarcator" for the Consume and Publish will provide the best throughput.
... View more
11-21-2023
01:50 PM
Why do you need to stop/terminate the connection? Sort of defeats how Kafka is meant to function.
... View more
10-09-2023
11:51 AM
1 Kudo
InvokeScriptedProcessor is the closest you'll get to a native (NAR) NiFi processor from my experience. With it, you do NOT need to define all three relationships...if your code handles all possible problems correctly, you could just have "success" or other for your relationship. From what I've seen you do need to have at least one relationship if you're modifying the FlowFile or creating new ones and require session.transfer to send it to that relationship. You don't need to transfer the original...if you read the original FlowFile and create a new one or several new ones you can dispose of the original with session.remove(your_orginal_flow_file)
... View more