messaging

Events

Event stream processing

Introduction

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.

Features

Consume

Consume events from a given topic.

Publish

Publish a event to the event stream.

Read

Read stored events

Example

Consume Request

Response

{
    "topic": "events",
    "message": {
        "id": "1",
        "type": "signup",
        "user": "john"
    }
}