【问题标题】:Kafka Salesforce sink connector - The Kafka record is missing the key _ObjectType which is used to identify the SObjectKafka Salesforce 接收器连接器 - Kafka 记录缺少用于识别 SObject 的键 _ObjectType
【发布时间】:2022-01-22 11:45:05
【问题描述】:
我正在使用融合云通过 SObject Sink 连接器将一些数据从 Kafka 接收到 Salesforce。连接已建立,但我遇到错误“Kafka 记录缺少用于识别 SObject 的键 _ObjectType。请在记录中包含 _ObjectType 字段”。任何人都知道出了什么问题?
Google 搜索并没有那么有用,因为它们将我引导到主要用于维护消息顺序的 Kafka 键/值概念
【问题讨论】:
标签:
salesforce
apache-kafka-connect
【解决方案1】:
您是否尝试将您在外部创建的随机记录接收到其他连接器?
来自overview docs
Salesforce SObjects 接收器连接器要求 Kafka 记录具有与 PushTopic 源连接器输出的记录相同的结构和格式
因此,如果您没有也使用“PushTopic 源连接器”或有偏离这些事件(SObjects)的“结构和格式”的记录,那么您应该期望看到一些错误。