当 Topic 或 Group 迁移失败时,您可在控制台上查看导致迁移失败的具体错误类型,并根据错误类型,采用相应修改方案,修改待迁移的 Topic 或 Group 配置。本文档介绍迁移数据配置的操作步骤。
开始迁移前,消息队列 Kafka版将自动校验待迁移的元数据,检查迁移的元数据配置是否符合规范,若检查到不符合规范的配置,则自动取消迁移,并给出相应错误类型。您可根据错误类型修改配置,各错误类型对应的修改方案如下。
Topic
校验项 | 错误类型 | 错误原因 | 修改方案 |
---|---|---|---|
Topic 名称 | 命名错误 | Topic 名称不符合规范 | 修改 Topic 名称,命名规范如下:
|
重命名 | Topic 名称重复 | 修改 Topic 名称,命名规范如下:
| |
分区数 | 分区数错误 | Topic 分区数不符合规范 | 修改 Topic 分区数,取值范围为 1~300。 说明 每个 Topic 的分区都会在 Kafka 实例内部打散存放,为保证分区在目标 Kafka 实例内能够均匀的被打散,建议设置各 Topic 分区的数量为目标 Kafka 实例 Broker 数量的整数倍,您可参考查看节点信息,查看实例的 Broker 数量。 |
副本数 | 副本数错误 | Topic 副本数不符合规范 | 修改 Topic 副本数,取值支持 1、2、3。 说明
|
最小同步副本数 | 最小同步副本数错误 | Topic 最小同步副本数不符合规范 | 修改 Topic 最小同步副本数,取值说明如下:
|
消息保留时长 | 消息保留时长错误 | Topic 消息保留时长不符合规范 | 修改 Topic 的消息保留时长,取值范围为 0~2160,单位为小时。 |
最大消息大小 | 最大消息大小错误 | Topic 最大消息大小不符合规范 | 修改 Topic 的最大消息大小,取值范围为 1MB~12MB。 |
消息清理策略 | 消息清理策略错误 | Topic 的消息清理策略取值不符合规范 | 修改消息清理策略取值,取值说明如下:
|
Topic 分区总数 | 所有 Topic 分区数总和过大,请减少分区 | 待迁移的 Topic 分区总数超过目标 Kafka 实例的可用分区数 |
|
Group
校验项 | 错误类型 | 错误原因 | 修改方案 |
---|---|---|---|
Group 名称 | 命名错误 | Group ID不符合规范 | 修改 Group ID,填写规范如下:
|
重命名 | Groud ID 重复 | 修改 Group ID,填写规范如下:
|
说明
各错误类型对应的修改方案,参见背景信息。