Kafka の高度な設定

ユーザー プロパティ

user.propertiesファイルを更新して、オプションの構成設定を指定します。

spring.profiles.active

デフォルト: local

Relational Migrator は、次のプロファイルで実行できます。

• kafka: 埋め込みサーバー配置を使用するリモート サーバー。

• confluent: マネージド Kafka に Confluent Cloud を使用するリモート サーバー。

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 接続 Java 管理拡張機能（JTX） URL

migrator.kafka.connect.metrics.jmx.ssl

デフォルト: false

SSL が有効になっている場合は、 をtrueに設定します。

migrator.kafka.connect.metrics.jmx.propertiesの前に付けることで、SSL 構成用のリモート Java マネジメント拡張機能（JTX）を追加で追加できます。

migrator.kafka.enable.topic.cleanup

デフォルト: false

前回の移行ジョブ中に作成されたトピックをクリーンアップします。

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

デフォルト: 5

ソース コネクタの場合、再試行可能な失敗での最大再試行回数を指定します。 Relational Migrator は、ジョブが失敗する前にソース データベースの再試行可能な障害から設定された制限まで回復を試みます。

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

デフォルト: 30000ミリ秒

ソース コネクタの場合、再試行可能な失敗後に再度起動するための遅延をミリ秒単位で指定します。 この値は再試行ごとに 2 倍に増えますが、 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 Connector の場合、再試行可能な失敗後に再度起動するための遅延をミリ秒単位で指定します。 この値は再試行ごとに 2 倍に増えますが、 migrator.connector.sink.common.errors.retry.delay.max.msを超えることはありません。

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

デフォルト: 60000ミリ秒

Sink Connector の場合、再試行可能な失敗後の再試行間の最大遅延をミリ秒単位で指定します。

スキーマ レジストリのプロパティ

プレフィックス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

これは、キー 変換用の Apiurio Registry の URL を指定します。

http://{host}:{port}またはhttps://{host}:{port}形式を使用します。

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

これは、値変換用の Apiリスト レジストリの URL を指定します。

http://{host}:{port}またはhttps://{host}:{port}形式を使用します。

Source Connector のプロパティ

Relational Migrator はデフォルト の Debezium ソース コネクタ プロパティを 設定します サポートされているソースデータベースごとに。コネクタ プロパティは、プレフィックスmigrator.connector.source.commonとともにuser.propertiesファイルに追加することで上書きできます。 例:

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

この例では、デフォルト値は 5 ですが、0 に設定されています。 つまり、再試行可能な失敗の後に再試行はありません。

Sink Connector のプロパティ

Relational Migrator がデフォルトの Migrator シンク コネクタ プロパティを 設定 サポートされているソースデータベースごとに。コネクタ プロパティは、プレフィックスmigrator.connector.sink.commonとともにuser.propertiesファイルに追加することで上書きできます。 例:

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

この例では、デフォルト値は 5 ですが、0 に設定されています。 つまり、再試行はありません。