Kafka是如何读写副本消息的?

appendRecords-副本写入
向副本底层日志写入消息的逻辑就实现在ReplicaManager#appendRecords。

Kafka需副本写入的场景:

生产者向Leader副本写入消息

Follower副本拉取消息后写入副本

仅该场景调用Partition对象的方法,其余3个都是调用appendRecords完成

消费者组写入组信息

事务管理器写入事务信息(包括事务标记、事务元数据等)
————————————————
版权声明:本文为CSDN博主「JavaEdge.」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/qq_33589510/article/details/122401683

文章评论

  加载评论内容,请稍等......