使用现有 Kafka 集群安装

在本页

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

开始之前

您必须确保在运行关系型迁移器的计算机上安装了Kafka以及与Kafka Connect集群的网络连接。

下载您源数据库的源连接器存档
解压缩存档。
复制debezium-connector.jar 文件到 debezium-connector 目录。
从下载的存档中，将 debezium-connector.jar 文件复制到 Kafka Connect 的 debezium-connector-xxx 目录，该目录位于您的 Kafka Connect 集群的 plugin.path。例如：/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 文件，请参阅 Migrator Installer Repository.
将 .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'
```

从下载中心选择关系型迁移器安装程序的最新版本。

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

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

属性名称	默认值	描述
`spring.profiles.active`	local	关系型迁移器可以在以下配置文件中运行 `kafka`：使用嵌入式服务器部署的远程服务器。 `confluent`：使用Confluent Cloud管理的Kafka的远程服务器将配置文件值设置为`kafka`。
`server.port`	8278	关系型迁移器应用程序运行在的端口号。
`migrator.kafka.bootstrap.servers`	无默认值	这是一个包含您的现有kafka集群的`host:port`对的列表。有关更多信息，请参阅Worker 配置属性。
`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`

启动关系型迁移器并检查日志。确认 Kafka 配置文件已激活且没有错误。

您的 log 文件位于操作系统特定的位置。有关更多信息，请参阅关系型迁移器文件位置。

与 Kafka 集成

下一步

使用 Docker 容器化集群