Kafka消息模型
2023-01-28 16:08:30 21 举报
Kafka消息模型
作者其他创作
大纲/内容
Partition(leader)
Partition
message1：offset=0
Consumer Group1
follower
kafka集群
Consumer1
Kafka中的副本节点是不提供服务的，纯粹的备份follower会向leader发送请求，让leader将最新的消息发送给它
一个Broder本质上是一个进程，一般一个Broker独占一个机器资源，这样才能起到高可用的效果（相当于ES中的node）
message3：offset=2
Consumer3
Consumer2
Brokder
Producer
Consumer Group2
就相当于ES中的Sharding、HBase中的Region
对于一个消费组来说，它不需要感知到其它的消费组，在它眼里主题是独占的每个消费组都消费主题中一份完整的消息
message2：offset=1
Topic
消费者自己维护自己的partition消费位移
收藏
职业：暂无
0 条评论
回复 删除
下一页
