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
加载评论内容,请稍等......