kafka创建Topic的时候 什么时候在Broker磁盘上创建的日志文件?
当Controller监听zk节点
/brokers/topics
变更之后,将新增的Topic 解析好的分区状态流转NonExistentPartition
->NewPartition
->OnlinePartition
当流转到OnlinePartition
的时候会像分区分配到的Broker发送一个leaderAndIsrRequest
请求,当Broker们收到这个请求之后,根据请求参数做一些处理,其中就包括检查自身有没有这个分区副本的本地Log;如果没有的话就重新创建;
???? Topic创建流程深度解析请看下文 ???????? 创建Topic的源码解析 ????
可帮忙 「 内推 」一二线大厂
你好,我是石臻臻,工作8年的互联网老兵,丰富的开发和管理经验, 现在任职于「 滴滴技术专家 」岗位,从事开源建设工作,公众号讲解 Java/中间件/大数据 等技术栈相关内容,欢迎关注石臻臻,进滴滴 「 高质量 」 「 滴滴开源技术答疑群 」 , 群内每周技术专家轮流值班答疑,加石臻臻微信交个朋友,交流交流技术分享分享生活