Data Formats

Raw JSON

原始 JSON 是一种由写入为字符串的 JSON 对象组成的数据格式。 您可以按如下方式用原始 JSON 表示样本文档：

"{\"company\":\"MongoDB\"}"

JSONstring在源连接器或接收器Connector器上指定 转换器时，可以使用原始 。要查看指定string转换器的Connector配置，请参阅 转换器指南。

BSON

BSON 是类似 JSON 对象的二进制序列化编码。BSON 对示例文档进行如下编码：

\x1a\x00\x00\x00\x02company\x00\x08\x00\x00\x00MongoDB\x00\x00

连接器使用 BSON 格式从 MongoDB 部署发送和接收文档。

For more information on BSON, see the BSON specification.

JSON schema

JSON 模式是一种用于为 JSON 对象指定模式的语法。模式是附加到 Apache Kafka 主题的定义，用于定义该主题的有效值。

您可以使用 JSON schema 为示例文档指定模式，如下所示：

{
   "$schema":"http://json-schema.org/draft-07/schema",
   "$id":"unique id",
   "type":"object",
   "title":"Example Schema",
   "description":"JSON Schema for the sample document.",
   "required":[
      "company"
   ],
   "properties":{
      "company":{
         "$id":"another unique id",
         "type":"string",
         "title":"Company",
         "description":"A field to hold the name of a company"
      }
   },
   "additionalProperties":false
}

将 JSON 模式转换器应用到连接器时，您可以使用 JSON 模式。要查看指定 JSON 模式转换器的连接器配置，请参阅转换器指南。

有关更多信息，请参阅官方 JSON 模式网站。

Avro Schema

Avro 模式是一种基于 JSON 的模式定义语法。Avro 模式支持以下数据类型的规范：

• 基元类型

• 复杂类型

• 逻辑类型

您可按如下方式为示例文档构建 Avro 模式：

{
  "type": "record",
  "name": "example",
  "doc": "example documents have a company field",
  "fields": [
    {
      "name": "company",
      "type": "string"
    }
  ]
}

为 MongoDB Kafka 源连接器定义模式时，您可以使用 Avro 模式。

For a list of all Avro schema types, see the Apache Avro specification.

Avro 二进制编码

Avro 为 Avro 模式定义的 JSON 对象指定二进制序列化编码。

如果使用前面的 Avro 模式，您就可以用 Avro 二进制编码表示示例文档，如下所示：

\x0eMongoDB

当您在源连接器或接收器连接器上指定 Avro 转换器时，您可以使用 Avro 二进制编码。要查看指定 Avro 转换器的连接器配置，请参阅转换器指南。

To learn more about Avro binary encoding, see this section of the Avro specification.