在本文中,我将演示如何通过设置Salesforce 平台事件源连接器并使用属性文件作为 Kafka Connect 中的配置源,将数据从Salesforce 平台事件事件发送到Kafka 主题。
先决条件
- 销售队伍开发帐户
- 设置已连接的应用程序
- 平台活动
- 自我管理汇流平台(下面是有关如何设置https://dzone.com/articles/installing-and-configuring-confluent-platform-kafk的教程)
- 卡夫卡连接销售队伍连接器
指示
1. 在 Salesforce 中创建新的”已连接应用程序“。转到“设置“,在”快速查找”框中搜索应用管理器,然后单击应用管理器,然后单击”新连接的应用 “以设置新的 API 客户端。
我们需要 Salesforce 提供以下详细信息:
- 使用者密钥– 可以从已连接的应用程序检索。
- 使用者密钥– 可以从已连接的应用程序检索。
- 用户名= 您用于登录到 Salesforce 的用户名。
- 密码= 用于登录到 Salesforce 的密码。
- 安全令牌– 可以从 Salesforce 中的配置文件设置生成。
2. 在销售队伍中创建平台活动。从”设置”中,在”快速查找”框中输入平台事件,然后选择”平台事件”。在平台活动页面上,单击“新平台活动“。
有关如何设置,请参阅此跟踪头模块。
3. 通过执行命令安装 Kafka 连接销售人员连接器
汇流集线器安装汇因因/卡夫卡连接-销售队伍:在您的汇能平台服务器上的最新。
4. 通过执行命令汇入本地停止和汇入本地启动来重新启动汇入服务
5. 转到汇流控制中心http://<公共 IP>:9021
在”连接“选项卡上,单击”添加连接器“,您应该看到所有可用的连接器,包括新安装的 Salesforce 源和接收器连接器。
6. 通过访问“主题”选项卡并单击”添加主题”按钮,在“汇流控制中心“中创建新主题。使用默认设置创建。
主题名称:sf_cloud_news_pe_in
7属性文件包含Salesforce 平台事件源连接器的愿望配置, 将其保存到您的本地,我们将将其上传到汇控控制中心。
属性文件
xxxxxxx
1
32