What's EventBus
Defination of EventBus:
- A realtime event bus / message bus.
- A central place to manage / trace / monitor events.
- A data collecting / distributing platform.
Following are some details of the defination:
- First of all, EventBus intend to be a realtime system. It offers low latency, high throughput ways to transfer data from one side to another side.
- Besides to be a realtime system, It encourages unified format of events/messages (defualt using ActivityStreams 1.0 format), But not mandatory.
- Along with the unified format, all isolated systems could understand what the event means (at least the semantic), a event could be shared between different systems.
for example: a user-info-update event, will be used by system-a, system-b, system-c, since they all understand the structure of the event - Another usage of us is for data collecting.
Since all events are go through here. We are collecting interested events on this central point to our data warehouse for data mining and meachine learning. And since the format are unified, ETL could be more easier.
Features
- Low latency and High throughput.
- Based on Reactive Streams, The whole workflow supports backpressure and various stream operations.
- Failure tolerance.
- Logic can be easily composed by various Sources, Sinks, Transforms, Fallbacks, And they are expendable.
- Tracking and Monitoring supported.
Contributing
Feedbacks and pull requests are welcome and appreciative. For major changes, please open an issue first to discuss what you would like to change.