使用 Confluent Cloud 安装

在此页面上

开始之前

步骤
后续步骤
了解详情

您可以使用 Confluent Cloud 配置 Relational Migrator with Kafka 。使用 Confluent Cloud 配置 Relational Migrator 可为您的部署提供 Kafka 的可靠性，而无需管理自己的 Kafka 集群。

开始之前

您必须在计算机上安装 Relational Migrator。要下载 Relational Migrator，请参阅下载中心。
由于 Confluence 的限制，您只能使用 Basic、Standard 和 Dedicated 集群。对于大多数使用案例，基本和标准集群足以处理大量数据的迁移。

步骤

创建 Confluent Cloud 环境

GoConfluent Cloud 并创建一个新环境。

启用模式注册表

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

如果要迁移的表超过1000个，请使用高级模式注册表层。否则，Essentials 层就足够了。

创建集群

导航至您的 Environment页面。单击Add Cluster 。

基本层和标准层集群足以满足大多数使用案例。如果要迁移大量数据，请考虑使用专用集群层。

配置权限并收集 API 密钥

要配置Relational Migrator，您必须配置并收集 Cloud API密钥和Kafka Cluster API密钥。您需要将它们包含在您的 user.properties文件中。 user.properties文件的位置因操作系统而异。有关更多信息，请参阅 Relational Migrator文件位置。

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

配置 Confluent Cloud API 密钥
在 Confluence 控制台的右上角，单击图标。在Administration下，选择Cloud API Keys 。
创建 Confluent Cloud API 密钥并为其配置权限。您有两种权限选项：
- 授予全局访问权限。
- 创建服务帐户并授予精细访问权限。
如果创建服务帐户，则必须为环境添加Operator角色，并向集群添加CloudClusterAdmin角色。
创建后，保存 API 密钥和密码。这些值将作为migrator.confluent.cloud-credentials.api-key和migrator.confluent.cloud-credentials.api-secret添加到您的user.properties文件中。
有关更多信息，请参阅使用 API 密钥控制 Confluent Cloud 中的访问。
配置 Kafka 集群 API 密钥
要访问 Kafka 集群，您必须配置 Kafka 集群 API 密钥。导航到您的Cluster Overview 。在左侧面板中，单击API Keys以创建 Kafka 集群 API 密钥。
保存 API 密钥和密码。这些值将作为migrator.confluent.kafka-credentials.api-key和migrator.confluent.kafka-credentials.api-secret添加到您的user.properties文件中。
有关更多信息，请参阅使用 API 密钥控制 Confluent Cloud 中的访问。

收集更多配置信息

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

查找并保存您的环境ID
从Environments概述页面中，选择您的云环境。环境 ID 位于右侧面板中环境名称下方。
一般环境ID形式为：
```
env-ab1cde
```
查找并保存集群 ID
导航到Cluster Overview页面，在右侧信息面板中找到您的集群 ID。
一般集群 ID 形式为：
```
abc-1test2
```
查找并保存集群的 Bootstrap 服务器
在Cluster Overview页面中，使用左侧导航并点击Cluster Settings 。在Cluster Settings页面上，找到集群的 Bootstrap服务器。
Bootstrap 服务器的一般形式为：
```
xxx-xxxxx.region.provider.confluent.cloud:9092
```
查找并保存集群 REST 端点
在Cluster Settings页面上，找到集群的 REST 端点。
一般 REST 端点形式为：
```
https://xxx-xxxxx.region.provider.confluent.cloud:443
```

将配置属性添加到`user.properties` 文件

user.properties文件的位置因操作系统而异。有关详细信息，请参阅Relational Migrator 文件位置。

使用以下示例将配置属性添加到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>

重新启动Relational Migrator

退出Relational Migrator ，然后重新启动。

确认安装成功

启动 Relational Migrator。在您的项目中，导航到Data Migration标签页。如果安装成功，右上角会出现Confluent Deployment model符号。

如果出现错误，请检查您的log文件。 log文件位置因操作系统而异。有关详细信息，请参阅Relational Migrator文件位置。

点击放大

后续步骤

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

了解详情

后退

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

来年

高级 Kafka 设置