我们都知道 Kafka 的 topic 资源比较“贵”，所以一般会给项目 topic 权限限制，按需申请。Milvus 会在建新表时自动申请 kafka topic 资源，这时候自动申请不到怎么办？手动配置 topic 要符合什么规范才能被 Milvus 使用？
通过本文的小实践，大家可以了解 Milvus 如何为 Kafka Topic 命名、使用 Topic 的机制，以及用户在 Kafka Topic 资源权限紧张情况下，对 Kafka Topic 的预设及使用。希望能给大家启发的同时增加对 Milvus 消息系统的了解。
Topic 在 Milvus 中的作用
Kafka 是一个分布式流处理系统，流处理系统使它可以像消息队列一样 publish 或者 subscribe 消息。Topic 用于建立 Producer 和 Consumer 之间的订阅关系。生产者发送消息到指定的 Topic，消息者从这个 Topic 下面消费消息（Kafka 把消息存在 topic 中，每一条消息包含 key、value、timestamp）。
在Milvus 2.x 中，流式消息经过 Proxy 生产到 Kafka topic 中，再由 Data Node 节点消费到对象存储中。
参考链接：https://milvus.io/docs/data_processing.md
Milvus Kafka Topic 命名规则
命名规则
配置文件中的 chanNamePrefix：
# Channel name generation rule: ${namePrefix}-${ChannelIdx}
common:
chanNamePrefix:
cluster: "by-dev"
rootCoordDml: "rootcoord-dml"
rootCoordDelta: "rootcoord-delta"
dataCoordTimeTick: "datacoord-timetick-channel"
Milvus 会创建三种类型的 Topic：
Datacoord-timetick-channel——chanNamePrefix.cluster-chanNamePrefix.dataCoordTimeTick
by-dev-datacoord-timetick-channel
Dml channel--chanNamePrefix.cluster-chanNamePrefix.rootCoordDml
1 by-dev-rootcoord-dml_0
2 ...
3 by-dev-rootcoord-dml_255
Delta channel--chanNamePrefix.cluster-chanNamePrefix.rootCoordDelta
1 by-dev-rootcoord-delta_0
2 ...
3 by-dev-rootcoord-delta_255机制
1. 在启动 Milvus 集群时，会创建唯一的 dataCoordTimeTick：by-dev-datacoord-timetick-channel。
2. 当创建一个新的 Collection 时，系统会创建对应的 rootCoordDml 和 rootCoordDelta 。由于一个表默认有 2 个 shard number ，共创建 2*2 共 4 个 topic（若shard number 为 4 ，则创建 4*2 个 topic，以此类推），名称如下：
1 by-dev-rootcoord-dml_0
2 by-dev-rootcoord-dml_1
3 by-dev-rootcoord-delta_0
4 by-dev-rootcoord-delta_1默认 rootCoord.dmlChannelNum 是 256（需要注意的是在新版本中我们调低了默认值），意思是最多创建 dml-channel topic 256 个，如果 collection 数量所需 topic 超过该值，则会对 topic 进行复用。所以我们可以通过控制 rootCoord.dmlChannelNum 来控制 topic 的复用。
Milvus Kafka Topic 预设方案
在了解了Milvus 对 Topic 的命名和复用规则之后，我们可以按规则预设 Kafka Topic。
1. 根据命名规则预设对应的 rootCoordDml 和 rootCoordDelta 相关 Topic。
1 by-dev-rootcoord-dml_2
2 by-dev-rootcoord-dml_3
3 by-dev-rootcoord-delta_2
4 by-dev-rootcoord-delta_3
2. 修改 rootCoord.dmlChannelNum 参数为4，控制 dml-channel topic 的使用数量。
3. 在系统读取到预设 topic 时直接使用，不再重新申请。
（本文作者张翔系 Zilliz 客户工程师；曾杰系 Zilliz 主任工程师）
本文分享自微信公众号 - ZILLIZ（Zilliztech）。
如有侵权，请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”，欢迎正在阅读的你也加入，一起分享。
