配置 Milvus Topic

本文为您介绍如何确认在新建 Milvus 数据源时，选择的 Topic 覆盖了增量同步所需要的所有 Topic。

检查 Topic 数量

1. 通过查看 Milvus 数据库中的配置 dmlChannelNum 来查询 Milvus DML 通道数量。通常默认值为 16，在 milvus.yaml 文件中记录。

2. Milvus 数据库自动创建的 Topic 格式说明。

   ${msgChannel.chanNamePrefix.cluster}-${msgChannel.chanNamePrefix.rootCoordDml}_{num} 
   

   说明

   {num} 的范围为 0 ~ dmlChannelNum -1。

3. 检查 Milvus 数据库自动创建的 Topic 数量是否和 dmlChannelNum 对应。Topic 创建完整后，默认有 16 个。

   by-dev-rootcoord-dml_0
   by-dev-rootcoord-dml_1
   by-dev-rootcoord-dml_10
   by-dev-rootcoord-dml_11
   by-dev-rootcoord-dml_12
   by-dev-rootcoord-dml_13
   by-dev-rootcoord-dml_14
   by-dev-rootcoord-dml_15
   by-dev-rootcoord-dml_2
   by-dev-rootcoord-dml_3
   by-dev-rootcoord-dml_4
   by-dev-rootcoord-dml_5
   by-dev-rootcoord-dml_6
   by-dev-rootcoord-dml_7
   by-dev-rootcoord-dml_8
   by-dev-rootcoord-dml_9
   

4. 如果检查 Topic 没有达到 dmlChannelNum 相等的值，您可以创建一个 Collection 指定分片数量（numShards）为 dmlChannelNum。

创建 Collection 并指定分片数量

您可以通过 Python、Java 和 Attu 三种方式创建 Collection 并指定分片数量 numShards。

Python

client.create_collection(
    collection_name="collection_name",
    schema=schema,
    # highlight-next-line
    num_shards=16
)

Java

CreateCollectionReq createRequest = CreateCollectionReq.builder()
    .collectionName("collection_name")
    .collectionSchema(collectionSchema) // 已创建的 Schema
    .numShards(16)
    .build();
client.createCollection(createRequest);

Attu

1. 使用 Attu 连接 Milvus 服务器。

2. 在 数据库 区域，单击需要创建 Collection 的数据库名称。

3. 在 Collections 页签，单击 创建 Collection。

4. 在 创建 Collection 对话框，配置各项参数及指定 分片数量。

   

5. 配置完成后，单击 创建。