在本指南中，您可以了解如何指定要在JSON MongoDBKafka源 中使用的内置connector 格式化程序类。 JSON 格式化程序 指定 JSON 数据的显示方式。 它们说明connector在输出数据时如何表示不同类型。 下表描述了源connector中可用的格式化程序类： com.mongodb.kafka.connect.source.json.formatter.DefaultJson 传统的严格 JSON 格式化程序。 com.mongodb.kafka.connect.source.json.formatter.ExtendedJson 完全类型安全的扩展 JSON 格式化程序。 此格式化程序强调类型保留，并用 BSON 类型表示大多数值。 com.mongodb.kafka.connect.source.json.formatter.SimplifiedJson 简化的 JSON 格式化程序。 此格式化程序将 ObjectId 、 Decimal 、 Date 和 Binary 值表示为字符串。 下表描述了本指南中的示例用于演示每种输出格式的示例文档的字段。 这些列描述了每个字段或嵌套字段的字段名称、值和类型。 ObjectID ( $oid ) 数组： - Decimal128 ( $numberDecimal ) - Double ( $numberDouble ) Binary ( $binary ) 包含字段的文档： - a : Boolean - b : Int32 ( $numberInt ) - c : String 在源connector的配置属性中，设置以下属性以指定默认的JSON格式化程序： 当您从 Kafka 主题输出样本文档内容时，输出会显示以下类型表示： ObjectId 值及其 BSON 类型 ObjectId 值及其 BSON 类型 Decimal 值及其 BSON 类型 Decimal 值及其 BSON 类型 Binary 值及其缓冲区string和二进制类型 Binary 值及其缓冲区string和二进制类型 Date 自 UNIX 纪元以来的毫秒值 Date 自 UNIX 纪元以来的毫秒值

在源connector的配置属性中，设置以下属性以指定扩展JSON格式化程序： 当您从 Kafka 主题输出样本文档内容时，输出会显示以下类型表示： ObjectId 值及其 BSON 类型 ObjectId 值及其 BSON 类型 Decimal 值及其 BSON 类型 Decimal 值及其 BSON 类型 Double 值及其 BSON 类型 Double 值及其 BSON 类型 Binary 值及其缓冲区string和二进制类型 Binary 值及其缓冲区string和二进制类型 Date 自 UNIX 纪元以来的毫秒值 Date 自 UNIX 纪元以来的毫秒值 Int32 值及其 BSON 类型 Int32 值及其 BSON 类型 在源connector的配置属性中，设置以下属性以指定简化的JSON格式化程序： 当您从 Kafka 主题输出样本文档内容时，输出会显示以下类型表示： ObjectId 十六进制string形式的值 ObjectId 十六进制string形式的值 Decimal string形式的值 Decimal string形式的值 Binary 值作为其缓冲区string Binary 值作为其缓冲区string Date string形式的值 Date string形式的值