Rust Events

这是一个在消息 API 上添加抽象层的实验。该项目受到 Mass Transit 的启发：对底层消息架构的拓扑结构做出一些决策，使其易于创建消息类型（“事件”）。

主要功能

多租户

每个事件可以可选地附加一个租户，这只是一个任意字符串。消费者可以监听所有或特定租户的事件。

支持的后端

RabbitMQ

通过 lapin 支持 RabbitMQ。

目前您不能选择拓扑结构，但希望在未来某个阶段我们可以添加自定义它的方法。

Kafka

通过 rust-rdkafka 支持 Kafka。

其他

许可证

在 MIT 许可证下授权。

运行测试

由于是集成测试，请禁用并行测试：RUST_LOG=info cargo test -- --nocapture --test-threads=1

lib.rs:

为 Kafka 实现事件管理器