[metaq]Consumer

Metaq是一个类是kafka的消息系统,开源地址https://github.com/killme2008/Metamorphosis。 基于Pull的消息系统,consumer端保持了很多逻辑,比如当前拉取消息的offset,loadbalance等,使用zookeeper作为coordination。 简单类图 核心类ZKLoadRebalanceListener,负责集群感知,当有brok
相关文章
相关标签/搜索
本站公众号
   欢迎关注本站公众号,获取更多信息