为 Microsoft Fabric Eventstream 添加提取

按照说明添加 Microsoft Fabric Eventstream 源。

开始之前

确保：

复查特定于此源连接类型的详细信息。
在大数据部署控制台中创建身份证明：
1. 从部署详细信息页面启动大数据部署控制台，然后登录。
2. 在管理服务的左侧导航菜单中，选择 DB Connections（DB 连接）。
3. 在“DB Connections（数据库连接）”页面上，选择“Add Credential（添加身份证明）”（加号图标）。
4. 在提供的字段中输入以下详细信息，然后选择提交：
  - 对于 Credential Domain ，输入 OracleGoldenGate。
  - 对于身份证明别名，输入 kafka。
  - 对于用户 ID ：输入 kafka://
  - 对于 Password（密码），输入密码。
  - 对于 Verify Password ，再次输入密码。

添加提取

在 OCI GoldenGate 部署控制台导航菜单中，选择提取。
在“提取”页上，选择添加提取。
在“添加提取”面板的提取信息页上，根据需要填写以下字段，然后选择下一步：
- 输入进程名称，长度不超过 8 个字符。
- 输入说明（可选）以帮助您区分此流程与其他流程。
- 从下拉列表中选择源。
在提取选项页上，根据需要填写以下字段，然后选择下一步：
1. 对于提取线索：
  1. 输入“提取”流程的名称。
  2. 输入子目录名称以设置生成的线索文件的定制位置。
  3. 输入线索序号以设置线索文件的起始编号。
  4. 输入线索大小以设置生成的线索文件的最大大小。
  5. 选择 Encryption Profile（加密配置文件）。如果未创建加密配置文件，则默认情况下会选择本地 Wallet 配置文件。
  6. 选择加密算法：
    - NONE（无）
    - AES256
    - AES192
    - AES128
2. 对于源身份证明，选择：
  1. 域
  2. 别名
  3. 何时/何地开始
在托管选项页面上，根据需要填写以下可选字段，然后选择下一步：
- 概要文件名
- 对于部署的健康状况至关重要
- 自动启动
- 自动重新启动
  
  注：通过添加配置文件和配置“自动启动”和“自动重新启动”选项，您的部署可以在网络中断后自动重新启动。要了解详细信息，请参阅配置托管流程。
在“参数文件”页上，更新以下内容：
1. 将 SOURCEDB USERIDALIAS 更新为 SOURCEDB USERIDALIAS kafka DOMAIN OracleGoldenGate
2. 将表映射保留原样 (TABLE source.*;)，以侦听给定引导服务器中的所有主题。要从指定的主题捕获，请将映射更改为 TABLE source.<topic-name>;，其中 <topic-name> 是要从中捕获的主题的名称。
  
  注：提取映射格式为 Table SourceSchema.Table。在 Kafka 中，没有源方案/表。OCI GoldenGate 将第一部分（“上一步中的源”）写入方案名称，第二部分写入表名称以跟踪文件。通过这种方式，可以将捕获的 kafka 消息复制到其他 GoldenGate 支持的目标。
选择创建并运行以创建并启动提取。如果选择创建，则稍后可以从“提取”页面手动启动提取。