使用现有 Kafka 集群安装

在此页面上

您可以在现有 Kafka 集群（包括 Kafka Connect）上安装 Relational Migrator。如果您已经在运行 Kafka 或者有自己的方法来安装和配置 Kafka，则此安装方法是理想的选择。

开始之前

您必须具有 Kafka 以及从运行 Relational Migrator 的计算机到 Kafka Connect 集群的网络连接。

下载源数据库的源Connector存档：
解压缩存档文件。
将 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'
```

下载最新版本的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 安装程序。

要在kafka-integrated模式下运行，请更新user.properties文件中的以下配置。

您的user.properties文件位于特定于操作系统的位置。有关更多信息，请参阅 Relational Migrator文件位置。

属性名称	默认	说明
`spring.profiles.active`	local	Relational Migrator可以在以下配置文件中运行： `kafka`：使用嵌入式服务器部署的远程服务器。 `confluent`：使用 Confluent Cloud 进行托管Kafka的远程服务器将配置文件值设置为`kafka` 。
`server.port`	8278	Relation Migrator 应用程序运行的端口。
`migrator.kafka.bootstrap.servers`	无默认值	这是预先存在的Kafka集群的 `host:port` 对的列表。有关更多信息，请参阅工作线程配置属性。
`migrator.kafka.connect.url`	无默认值	使用`{host}:{port}`格式的Kafka Connect托管URL。
`migrator.kafka.connect.metrics.jmx.service.url`	无默认值	Kafka Connect Java 管理扩展 (JMX) URL。例如： `service:jmx:rmi:///jndi/rmi://localhost:9876/jmxrmi`

启动 Relational Migrator 并检查日志。确认 Kafka 配置文件处于活动状态并且没有错误。

您的log文件位于特定于操作系统的位置。有关详细信息，请参阅Relational Migrator文件位置。

后退

与Kafka集成

来年

将容器化集群与Docker结合使用