Kafka的选举机制

 

Kafka集群中有一个broker会被选举为Controller,负责管理集群broker的上下线,所有topic的分区副本分配和leader选举等工作,而对Controller的管理依赖于zk

leader的选举过程

Kafka发送消息流程与选举机制

 

 

Kafka的发送消息流程

 

Kafka的producer发送消息采用异步的形式,在消息发送过程中,涉及到了两个线程——main线程和Sender线程,以及一个线程共享变量——RecordAccumulator。main线程将消息发送给RecordAccumulator,Sender线程不断从RecordAccumulator中;拉取消息发送到Kafka broker中

思考,为什么要引入RecordAccumulator?

Kafka发送消息流程与选举机制

 

main线程的执行流程:

先执行过滤器对不合法的要求进行过滤,然后对其进行序列化,最后再进行的分片 

相关文章:

  • 2021-05-19
  • 2021-05-03
  • 2022-02-18
  • 2022-12-23
  • 2021-10-27
  • 2021-08-23
  • 2021-06-13
  • 2022-12-23
猜你喜欢
  • 2021-07-10
  • 2022-01-14
  • 2021-11-15
  • 2021-05-05
  • 2022-12-23
  • 2021-10-31
  • 2021-07-10
相关资源
相似解决方案