我们在之前的Kafka源码分析系列中介绍过kafka集群的metadata, 大家可以参考一下;
简单说, kafka集群的metadata包括:
所有broker的信息: ip和port;
所有...librdkafka中对metadata的封装和操作,基本上就是metadata的获取,定时刷新以及引用的操作, 比如说partition leader的迁移, partition个数的变化, broker...rd_kafka_broker_unlock(rkb);
// 解析并添充broker信息
.
.
.
// 解析并添充topic和partition..., 处理partition的新增和减少, 都是通过op作的异步操作
rd_kafka_topic_metadata_update2(rkb, mdt);...rd_kafka_wrunlock(rk);
}
}
}
// 对没有获取到