Nicolas Fraenkel shows off data from Hazelcast in Kibana:
Hazelcast data pipelines work by regularly polling the source. With an HTTP endpoint, that’s straightforward, but with SSE, not so much as SSE relies on subscription. Hence, we need to implement a custom
Sourceand design it around an internal queue to store the changes as they arrive, while polling will dequeue and send them further down the pipeline.
Read on for code and explanation.