kafka proxy业务流程
2017-06-16 12:07:42 0 举报
kafka-proxy
作者其他创作
大纲/内容
proxycluster
proxy层
共享内存
路由总路口（生产／消费）
partition2
broker2
proxy05
consumerID对应的consumer thread（消费数据）
1、创建消费组2、销毁消费组3、生产4、消费
proxy02
consumerId 对应topic消费分区数
partition5
proxy01
topic==cluster
consumers
proxy04
consumer-3
proxycache
partition3
broker1
consumer-2
groupName
broker3
Kafka集群
partition6
消费的token信息(消费验证)
proxy本地缓存
partition4
存储路由信息、与console对接进行管理
consumer-1
partition1
consumerID对应的proxy server（消费数据）
consumerId 最后一批拉取的数据，以及对应的序列号
proxy03
producerID==proxy server
收藏
0 条评论
回复 删除
下一页
