使用现有 Kafka 集群安装
您可以在现有 Kafka 集群(包括 Kafka Connect)上安装 Relational Migrator。 如果您已经在运行 Kafka 或者有自己的方法来安装和配置 Kafka,则此安装方法是理想的选择。
开始之前
您必须具有 Kafka 以及从运行 Relational Migrator 的计算机到 Kafka Connect 集群的网络连接。
步骤
安装 Debezium Source Connect 插件
下载源数据库的源连接器存档:
解压缩存档文件。
将
debezium-connector.jar
文件复制到debezium-connector
目录。从下载的存档中,将
debezium-connector.jar
文件复制到debezium-connector-xxx
Kafka Connect 的 plugin.path 中的 目录 在 Kafka Connect 集群上。例如:/kafka/connect/debezium-connector-sqlserver
。重新启动 Kafka Connect 集群。
成功注册插件后,
kafka-connect
启动日志中会显示以下日志语句:INFO || Added plugin 'io.debezium.connector.sqlserver.SqlServerConnector'
安装 Relational Migrator Sink Connect 插件
下载最新版本的
kafka-connect-migrator.jar
文件。要下载最新的
kafka-connect-migrator.jar
文件,请参阅 迁移器安装程序存储库。将
.jar
文件复制到kafka-connect-migrator
目录。新的
kafka-connect-migrator
目录可在 Kafka Connect 的 plugin.path 中找到 。例如:/kafka/connect/kafka-connect-migrator
。重新启动 Kafka Connect 集群。
成功注册插件后,
kafka-connect
启动日志中会显示以下日志语句:INFO || Added plugin 'com.mongodb.migrator.kafka.connect.MigratorSinkConnector'
安装 Relational Migrator
从下载中心,选择最新版本的 Relational Migrator 安装程序。
在 kafka 集成模式下运行 Relational Migrator
要在kafka-integrated
模式下运行,请更新user.properties
文件中的以下配置。
您的user.properties
文件位于操作系统的特定位置。有关更多信息,请参阅 Relational Migrator 文件位置。
属性名称 | 默认 | 说明 |
---|---|---|
spring.profiles.active | local | Relational Migrator 可以在以下配置文件中运行:
将配置文件值设置为 |
server.port | 8278 | Relation Migrator 应用程序运行的端口。 |
migrator.kafka.bootstrap.servers | 无默认值 | 这是预先存在的 kafka 集群的 有关更多信息,请参阅 工作线程配置属性。 |
migrator.kafka.connect.url | 无默认值 | 使用 {host}:{port} 格式的 Kafka Connect 主机 URL。 |
migrator.kafka.connect.metrics.jmx.service.url | 无默认值 | Kafka Connect Java 管理扩展 (JMX) URL。 例如: |
确认安装成功
启动 Relational Migrator 并检查日志。 确认 Kafka 配置文件处于活动状态并且没有错误。
您的log
文件位于操作系统的特定位置。有关详细信息,请参阅Relational Migrator 文件位置。