在本文中,我将演示如何通过设置Salesforce 平台事件源连接器并使用属性文件作为 Kafka Connect 中的配置源,将数据从Salesforce 平台事件事件发送到Kafka 主题

先决条件

指示

1. 在 Salesforce 中创建新的”已连接应用程序“。转到“设置“,在”快速查找”框中搜索应用管理器,然后单击应用管理器,然后单击”新连接的应用 “以设置新的 API 客户端

我们需要 Salesforce 提供以下详细信息:

  • 使用者密钥– 可以从已连接的应用程序检索。
  • 使用者密钥– 可以从已连接的应用程序检索。
  • 用户名= 您用于登录到 Salesforce 的用户名。
  • 密码= 用于登录到 Salesforce 的密码。
  • 安全令牌– 可以从 Salesforce 中的配置文件设置生成。

manage connected apps

2. 在销售队伍中创建平台活动从”设置”中,在”快速查找”框中输入平台事件,然后选择”平台事件”。在平台活动页面上,单击“新平台活动“。

有关如何设置,请参阅此跟踪头模块。

https://trailhead.salesforce.com/en/content/learn/modules/platform_events_basics/platform_events_define_publish

setup platform event

3. 通过执行命令安装 Kafka 连接销售人员连接器

汇流集线器安装汇因因/卡夫卡连接-销售队伍:在您的汇能平台服务器上的最新。

root@ip

4. 通过执行命令汇入本地停止汇入本地启动来重新启动汇入服务

root@ip

5. 转到汇流控制中心http://<公共 IP>:9021

在”连接“选项卡上,单击”添加连接器“,您应该看到所有可用的连接器,包括新安装的 Salesforce 源和接收器连接器。

confluent

6. 通过访问“主题”选项卡并单击”添加主题”按钮,在“汇流控制中心“中创建新主题。使用默认设置创建。

主题名称:sf_cloud_news_pe_inchoosing a topic

7属性文件包含Salesforce 平台事件源连接器的愿望配置, 将其保存到您的本地,我们将将其上传到汇控控制中心

Salesforce 平台事件源连接器配置详细信息

属性文件

 

xxxxxxx
1
32