使用 Confluent Cloud 安装

创建Confluent Cloud环境

前往 Confluent Cloud 创建新的环境。

启用模式注册表

启用模式注册表并选择一个区域。

如果您有超过1000张表要迁移，请使用高级模式注册表层级。否则，基本层级就足够了。

创建集群

导航到您的环境页面。点击 添加集群。

基础和标准层级集群对大多数用例就足够了。如果您正在迁移大量数据，请考虑专用集群层级。

配置权限和收集API密钥

要配置关系型迁移器，您必须配置和收集云API密钥和Kafka集群API密钥。您需要将它们包含在您的user.properties文件中。您的user.properties文件的位置取决于您的操作系统。有关更多信息，请参阅关系型迁移器文件位置.

以下API密钥可在Confluent Cloud控制台中找到。有关更多信息，请参阅使用API密钥。

1. 配置Confluent Cloud API密钥

   在Confluent控制台的右上角，点击图标。在管理下，选择云API密钥。

   创建Confluent Cloud API密钥并为它们配置权限。您有两个权限选项

   • 授予全局访问权限。

   • 创建服务帐户并授予细粒度访问权限。

   如果您创建服务帐户，您必须为环境添加Operator角色，并将CloudClusterAdmin角色添加到集群。

   创建后，保存API密钥和密钥。这些值作为migrator.confluent.cloud-credentials.api-key和migrator.confluent.cloud-credentials.api-secret添加到您的user.properties文件中。

   有关更多信息，请参阅 在 Confluent Cloud 中使用 API 密钥控制访问。

2. 配置 Kafka 集群 API 密钥

   要访问您的 Kafka 集群，您必须配置 Kafka 集群 API 密钥。导航到您的 集群概览。在左侧面板中，单击 API 密钥 创建您的 Kafka 集群 API 密钥。

   保存 API 密钥和密钥。这些值将添加到您的 user.properties 文件中，作为 migrator.confluent.kafka-credentials.api-key 和 migrator.confluent.kafka-credentials.api-secret。

   有关更多信息，请参阅 在 Confluent Cloud 中使用 API 密钥控制访问。

收集更多配置信息

您可以在 Confluent Cloud 控制台中找到您的环境 ID、集群 ID、引导服务器和集群 REST 终端。有关更多信息，请参阅Confluent Cloud 文档。

1. 查找并保存您的环境 ID

   从您的 环境概览 页面，选择您的云环境。您的环境 ID 在右侧面板的环境名称下方。

   通用环境 ID 格式为

   env-ab1cde

2. 查找并保存您的集群 ID

   导航到您的 集群概览 页面，在右侧信息面板中找到您的集群 ID。

   通用集群 ID 格式为

   abc-1test2

3. 查找并保存您的集群的引导服务器

   从您的 集群概览 页面，使用左侧导航并点击 集群设置。在 集群设置 页面，找到您的集群的引导服务器。

   通用引导服务器格式为

   xxx-xxxxx.region.provider.confluent.cloud:9092

4. 查找并保存您的集群 REST 终端

   在 集群设置 页面，找到您的集群的 REST 终端。

   通用 REST 终端格式为

   https://xxx-xxxxx.region.provider.confluent.cloud:443

将配置属性添加到您的 user.properties 文件中

您的 user.properties 文件的存储位置因操作系统而异。有关更多信息，请参阅关系迁移器文件位置。

以下示例演示如何将配置属性添加到您的 user.properties 文件中

spring.profiles.active: confluent
migrator.confluent.environment.environment-id: <Environment ID>
migrator.confluent.environment.cluster-id: <Cluster ID>
migrator.confluent.environment.bootstrap-server: <xx.region.provider.confluent.cloud:9092>
migrator.confluent.environment.rest-endpoint: <https://xxx.region.provider.confluent.cloud:443>
migrator.confluent.cloud-credentials.api-key: <Cloud API key>
migrator.confluent.cloud-credentials.api-secret: <Cloud API Secret>
migrator.confluent.kafka-credentials.api-key: <Cluster API key>
migrator.confluent.kafka-credentials.api-secret: <Cluster API Secret>

重启关系型迁移器

退出关系型迁移器并重新启动。

确认安装成功

启动关系型迁移器。在您的项目中，导航到 数据迁移 选项卡。如果安装成功，右上角将出现 康威部署模型 图标。

如果出现错误，请检查您的 日志 文件。您的 日志 文件位置因操作系统而异。有关详细信息，请参阅 关系型迁移器文件位置。

点击放大