Kafka Salesforce 接收器连接器 - Kafka 记录缺少用于标识 SObject 的键 _ObjectType

Question

我正在使用 Confluence Cloud 通过 SObject Sink 连接器将一些数据从 Kafka 接收到 Salesforce。连接已建立，但我遇到错误“Kafka 记录缺少用于标识 SObject 的键 _ObjectType。请在记录中包含 _ObjectType 字段”。任何人都知道出了什么问题吗？

谷歌搜索并没有那么有用，因为它们引导我了解 Kafka 键/值概念，该概念主要用于维护消息的顺序

Answer 1

您是否正在尝试将您在外部创建的随机记录接收到其他连接器？

来自概述文档

Salesforce SObjects 接收器连接器要求 Kafka 记录具有与 PushTopic 源连接器输出的记录相同的结构和格式

因此，如果您不也使用“PushTopic 源连接器”或拥有偏离这些事件（SObject）“结构和格式”的记录，那么您应该会看到一些错误。

Answer 2

如果我理解正确的话。您必须传入“Id”属性及其值才能成功写入 salesforce。因为 Id 是一列，其值有助于识别已发布记录是否已存在或是否被视为插入。请尝试传入 Id 及其值，例如下面我传递了 JSON 负载，因为连接器的配置文件中有 JSON 转换器。

"payload": {
  "Id": "124421",
  "FirstName": "name",
}

Answer 3

我也在做同样的事情。您能指导一下您是如何做到这一点的吗？喜欢将数据从 kafka 转移到 salesforce 吗？