This space is so crowded and confusing. I had no idea of Flink, while I had just been introduced to Apex a while back. Both are from Apache. (I’m considering Onyx and will soon be comparing notes with a colleague who introduced Apex to me)

@jaju: just looked at Apex tutorial and it doesn't look developer-friendly to me

Started seeing

No implementation of method: :read-batch of protocol: #'onyx.peer.pipeline-extensions/Pipeline found for class: onyx.plugin.elasticsearch.ElasticsearchWrite

Must be because if I use [org.onyxplatform/onyx "0.9.6"] then it works

Try a lein clean

Yep that fixed it