Honestly I didn’t know where post these questions so I put here because I’m using java. Please move it if there is a better category.
I prefer to post a pastebin pic in order to explain my problem because I wrote a bit of code lines and it looks better on it.
Briefly: I have a Kafka broker and cluster with running Flink instance. I want to perform anomaly detection with HTM on the cluster feeding it with data coming from Kafka.
I have downloaded Flink-HTM from github and explored it to understand.
P.S.: If can help, I can attach also my custom deserializer and custom timestamp extractor code.
Thanks in advance,