高级 Kafka 设置

用户属性

通过更新您的 user.properties 文件来提供可选的配置设置。

spring.profiles.active

默认值: local

关系迁移器可以在以下配置文件中运行

• kafka: 使用嵌入式服务器部署的远程服务器。

• confluent: 使用 Confluent Cloud 进行管理的 Kafka 的远程服务器。

server.port

默认值: 8278

关系迁移器应用程序运行的端口。

migrator.kafka.bootstrap.servers

您现有 Kafka 集群的 host:port 对的列表。

例如： kafka-1:9092, kafka-2:9093。

有关更多信息，请参阅工作配置属性.

migrator.kafka.connect.url

使用 host:port 格式的 Kafka Connect 主机 URL。

例如： https://localhost:8083。

migrator.kafka.connect.metrics.jmx.service.url

Kafka Connect Java 管理扩展 (JMX) URL。

migrator.kafka.connect.metrics.jmx.ssl

默认值: false

如果启用了 SSL，请设置为 true。

您可以通过使用 migrator.kafka.connect.metrics.jmx.properties 前缀来添加额外的 SSL 配置的远程 Java 管理扩展 (JMX)。

migrator.kafka.enable.topic.cleanup

默认值: false

清理最后迁移作业期间创建的主题。

migrator.connector.source.common.errors.max.retries

默认值: 5

对于源连接器，它指定了可重试失败的最大重试次数。关系迁移器在作业失败之前尝试从源数据库的可重试失败中恢复，直到达到设定的限制。

migrator.connector.source.common.errors.retry.initial.max.ms

默认值: 30000 ms

对于源连接器，它指定了在可重试失败后再次启动的延迟（以毫秒为单位）。该值在每次重试后加倍，但不超过 migrator.connector.source.common.errors.retry.delay.max.ms。

migrator.connector.source.common.errors.retry.delay.max.ms

默认：60000 毫秒

对于源连接器，它指定在可重试失败后的重试之间最大延迟（毫秒）。

migrator.connector.sink.common.errors.max.retries

默认值: 5

对于目标连接器，它指定在可重试失败时的最大重试次数。关系迁移器在作业失败之前会尝试从源数据库的可重试失败中恢复，直到达到设置的极限。

migrator.connector.sink.common.errors.retry.initial.max.ms

默认值: 30000 ms

对于目标连接器，它指定在可重试失败后再次开始的延迟（毫秒）。每次重试后该值翻倍，但不超出 migrator.connector.sink.common.errors.retry.delay.max.ms。

migrator.connector.sink.common.errors.retry.delay.max.ms

默认：60000 毫秒

对于目标连接器，它指定在可重试失败后的重试之间最大延迟（毫秒）。

模式注册表属性

使用关系迁移器与任何模式注册表，通过向 user.properties 文件添加以 migrator.connector.properties.common 为前缀的属性来实现。

migrator.connector.properties.common.key.converter

默认：migrator.connector.properties.common.key.converter

消息键的转换器类。

migrator.connector.properties.common.value.converter

默认：org.apache.kafka.connect.json.JsonConverter

消息值的转换器类。

migrator.connector.properties.common.key.converter.apicurio.registry.url

这指定了键转换器的 Apicurio 注册表的 URL。

它使用 http://{host}:{port} 或 https://{host}:{port} 格式。

migrator.connector.properties.common.value.converter.apicurio.registry.url

这指定了值转换器的 Apicurio 注册表的 URL。

它使用 http://{host}:{port} 或 https://{host}:{port} 格式。

源连接器属性

关系迁移器为每个支持的数据源数据库设置默认的Debezium源连接器属性。可以通过在user.properties文件中添加前缀为migrator.connector.source.common的属性来覆盖连接器属性。例如

migrator.connector.source.common.errors.max.retries: 0

在这个例子中，默认值是五，但现在已设置为零。这意味着在可重试失败后没有重试。

目标连接器属性

关系型迁移器为每个支持的源数据库设置默认的迁移器 输出连接器属性。可以通过在 user.properties 文件中添加具有前缀 migrator.connector.sink.common 的属性来覆盖连接器属性。例如

migrator.connector.sink.common.errors.max.retries: 0

在这个示例中，默认值是五个，但现在已设置为零。这意味着没有重试。