Since no one mentioned it in the comments so far, please add Hazelcast Jet to the long list of stream processors : https://github.com/hazelcast/hazelcast-jet