Event stream processing

Publish and consume messages from a scalable persistent event stream. Group messages by topic and asynchronously notify listeners of new events occuring in real time. Messages are persisted in case consumers disconnect.