为 Confluent Kafka 添加复制

学习为 Confluent Kafka 添加复制进程。

开始之前

确保查看以下资源：

添加复制 (26ai)

要在 Oracle GoldenGate 26ai 中为 Confluent Kafka 添加复制：

在 OCI GoldenGate 部署控制台导航菜单中，选择 Replicat 。
在 "Replicat"（复制）页面上，选择 Add Replicat（添加复制）。
在“添加复制”面板的复制信息页上，根据需要填写字段，然后选择下一步：
- 选择复制类型：
  - 经典复制
  - 协调的复制
- 输入 Process Name（流程名称），长度不超过 5 个字符。
- 输入说明，以帮助区分此流程与其它流程。
在复制选项页上，根据需要填写字段，然后选择下一步：
- 复制线索：
  - 输入名称。
  - 如果希望 Trail 文件位于非默认位置，请输入 Subdirectory 。
  - 选择 Encryption profile 。如果未创建加密配置文件，则默认情况下会选择本地 Wallet。
  - 对于开始，选择数据处理的起点：
    - 日志中的位置（默认值）
    - Now
    - 定制时间
- 线索位置：
  - 输入序号。
  - 输入 RBA 偏移。
  - 从 Target（目标）下拉列表中选择 Kafka。
  - 启用 Kafka Connect 。
- 目标身份证明：
  - 选择域。
  - 选择指定域中的别名。
  - 选择检查点表。保留默认选择，或选择为目标部署创建的检查点表。
  - 选择 Max Threads Number （最大线程数）（仅限协调复制）。
在托管选项页面上，根据需要填写可选字段，然后选择下一步：
- 选择配置文件名称（如果有）。
- 对于部署的健康状况至关重要。
- 启用和配置自动启动设置。
在 Parameter File（参数文件）页面上，可以添加参数以进一步配置复制。例如：
```
table source.table1;
```
注:

默认情况下，GoldenGate 使用格林威治标准时间 (GMT)。使用 SETENV 覆盖复制的默认设置。此更改不适用于部署。例如：
```
setenv (TZ="US/Eastern")
setenv (TZ="GMT+5")
```
在 Properties File（属性文件）页面上，查看属性并确保根据需要为每个标记为 #TODO 的属性设置值。

例如，对于 gg.handler.kafkahandler.topicMappingTemplate=，输入流名称。

有关此目标属性的信息，请参阅 Oracle GoldenGate for Distributed Applications and Analytics 指南中的 Confluent Kafka (target) 。
选择创建并运行。如果选择创建，则以后可以从“复制”页手动启动复制。

添加复制 (21c)

要在 Oracle Goldengate 21 c 中为 Confluent Kafka 目标添加复制：

在 OCI GoldenGate 部署控制台的“管理服务概览”页上，选择添加复制（加号图标）。
在“添加复制”页上，选择复制类型，然后选择下一步。

复制的类型包括：
- 经典复制
- 协调的复制
在“复制选项”页面上，填写以下字段，然后选择下一步：
1. 对于流程名称，输入复制流程的名称。
2. （可选）对于说明，输入简要说明以将此复制与其他复制区分开来。
3. 对于线索名称，输入两个字符的线索名称。
4. 对于目标，从下拉列表中选择 Kafka 。
5. 对于可用别名，选择 Confluent Kafka 连接。
6. 启用 Kafka Connect 。
7. 对于 Converter ，选择 Avro 。
8. 对于 Confluent Schema Registry ，选择 Confluent Schema Registry 连接。
在“参数文件”页上，根据需要添加和配置复制参数，然后选择下一步。
注:

默认情况下，GoldenGate 使用格林威治标准时间 (GMT)。使用 SETENV 覆盖默认设置。例如：
```
setenv (TZ="US/Eastern")
setenv (TZ="GMT+5")
```
了解有关 SETENV 的更多信息。
在“Properties File（属性文件）”页上，配置以下 Kafka Connect 属性：
- 对于 gg.handler.kafkaconnect.topicMappingTemplate：提供 Confluent Kafka 主题名称。
选择创建并运行。如果选择创建，则稍后可以从“管理服务概览”页手动启动复制。

返回到“Administration Service Overview（管理服务概览）”页，在此页上可以查看复制进程的创建并访问复制操作。

Confluent Kafka 目标详细信息

为 Confluent Kafka 添加复制

开始之前

添加复制 (26ai)

添加复制 (21c)

相关产品