kafak

coding

安装略。

kafka角色

broker:一个kafka机器就是一个broker topic:一个消息队列的名称,比如"url-visit-topic" Partition:分区,比如一个topic("url-visit-topic")包含100个分区,这些分区可以分布到不同的kafka集群节点上,每一个partition是一个有序的队列,队列可以理解为一个数组,队列中的每一个消息,可以理解为每一个元素,都有一个消息都有一个id(offeset)来标识,就像数组中的元素都可以通过下表访问到一样。一个topic在集群中有多个partition,至于说消息应该发送到哪一个partition,这是有算法的(hash算法,可以是根据key来hash算法)

topic partition broker replia关系

假设有1个topic, 有四个分区,命名为p0,p1,p2,p3 假设有5个broker,命名为:b0,b1,b2,b3,b4 如果将分区的备份数设置为3,那么就会有p0分区的三个备份(p0-0,p0-1,p0-2)并且分别存储于对应的brokers 注意:备份分区的id和broker.id保持一致,对每一个分区kafka将会选举一个broker作为(leader)

Zookeeper在kafka集群中扮演角色

就说这么多吧

以上是 kafak 的全部内容, 来源链接: utcz.com/z/509933.html

回到顶部