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

Question

我使用合流云通过SObject sink连接器将一些数据从Kafka汇到Salesforce。建立了连接，但我遇到了一个错误"；Kafka记录缺少用于标识SObject的键_ObjectType。请在记录中包括_ObjectType字段"；。有人知道哪里出了问题错误吗？

谷歌搜索并没有那么有用，因为它们让我想到了Kafka Key/Value的概念，它主要用于维护消息的顺序

Answer 1

您是否试图将从外部创建的随机记录汇到其他连接器？

来自概览文档

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

因此，如果您不是，也使用"；PushTopic源连接器"；或者具有偏离"；结构和格式"；在这些事件(SObjects(中，那么您应该会看到一些错误。

Answer 2

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

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