This repository has been archived by the owner on Sep 15, 2023. It is now read-only.
ekafka/v0.3.0
·
124 commits
to master
since this release
- 新增 ConsumerGroup 的封装
- 新增 ConsumerServer 用于快速启动一个符合 Ego Component 规范的消费者