高级 Kafka 设置

用户属性

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

spring.profiles.active

默认值：本地

Relational Migrator 可以在以下配置文件中运行：

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

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

server.port

默认值：8278

Relational Migrator 应用程序运行的端口。

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

对于源connector ，它指定了可重试故障的最大重试次数。 在作业失败之前，Relational Migrator 会尝试从源数据库可重试故障中恢复，但不超过设定限制。

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

默认值： 30000毫秒

对于源连接器，它指定在发生可重试故障后再次启动的延迟（以毫秒为单位）。每次重试后，该值都会加倍，但不超过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

对于 Sink connector ，它指定了可重试故障的最大重试次数。 在作业失败之前，Relational Migrator 会尝试从源数据库可重试故障中恢复，但不超过设定限制。

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

默认值： 30000毫秒

对于 Sink 连接器，它指定了在发生可重试故障后再次启动的延迟时间（以毫秒为单位）。每次重试后，该值都会加倍，但不超过migrator.connector.sink.common.errors.retry.delay.max.ms 。

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

默认值： 60000毫秒

对于 Sink 连接器，它指定了可重试失败后两次重试之间的最大延迟（以毫秒为单位）。

模式注册表属性

通过向前缀为migrator.connector.properties.common的user.properties文件添加属性，将 Relational Migrator 与任何模式注册表结合使用。

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}格式。

源connector属性

Relational Migrator 设置默认 Debezium 源连接器属性 对于每个支持的源数据库。可以通过将连接器属性添加到前缀为 的user.properties migrator.connector.source.common文件中来覆盖连接器属性。例如：

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

在此示例中，默认值为 5，但现在已设置为零。这意味着可重试失败后无需重试。

接收器连接器属性

Relational Migrator 设置默认 Migrator 接收 器连接器属性 对于每个支持的源数据库。可以通过将连接器属性添加到前缀为 的user.properties migrator.connector.sink.common文件中来覆盖连接器属性。例如：

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

在此示例中，默认值为 5，但现在已设置为零。这意味着无需重试。