自管理Kafka设置指南

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

重要

本指南假定您熟悉Kafka。本文档和MongoDB支持不为设置、配置或管理Kafka集群提供支持。

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

下载源数据库的源Connector存档：
解压缩存档文件。
将 debezium-connector.jar文件复制到debezium-connector目录。
从下载的存档中，将 debezium-connector.jar 文件复制到 Kafka Connect 集群上 Kafka Connect 的 plugin.path 中的 debezium-connector-xxx 目录。示例：/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`	`kafka`
`server.port`	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`

有关 user.properties 文件的详细信息，请参阅用户属性。

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

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

验证安装成功后，可以创建新项目。

后退

Kafka部署

来年

Confluent Cloud