我们在之前的Kafka源码分析系列中介绍过kafka集群的metadata, 大家可以参考一下;
简单说, kafka集群的metadata包括:
所有broker的信息: ip和port;
所有...librdkafka中对metadata的封装和操作,基本上就是metadata的获取,定时刷新以及引用的操作, 比如说partition leader的迁移, partition个数的变化, broker..., 我们在分析broker时再具体介绍
// 已存在的更新,没有的新添加, 最终会开启一个新的broker的io event loop
for (i = 0 ; i md..., 处理partition的新增和减少, 都是通过op作的异步操作
rd_kafka_topic_metadata_update2(rkb, mdt);..., 设置新的刷新时间
rd_kafka_metadata_cache_hint(rk, topics, &q_topics,