JSON フォーマッタ
Overview
このガイドでは、MongoDB Kafka ソース コネクタで使用する組み込みの JSON 形式クラスを指定する方法を学習できます。
JSON フォーマッタ
JSON フォーマットは JSON データの表示方法を指定します。 コネクタがデータを出力するときにさまざまなタイプを表す方法に関する指示を提供します。
組み込みフォーマッタ
次の表では、ソース コネクタで使用できるフォーマッタ クラスについて説明します。
クラス | 説明 |
|---|---|
com.mongodb.kafka.connect.source.json.formatter.DefaultJson | レガシーの strict JSON 形式。 |
com.mongodb.kafka.connect.source.json.formatter.ExtendedJson | 完全に型安全性のある拡張 JSON フォーマッタ。 このフォーマットは型の保存を重視し、ほとんどの値を BSON 型で表します。 |
com.mongodb.kafka.connect.source.json.formatter.SimplifiedJson | 簡略化された JSON フォーマッタ。 このフォーマットは、 ObjectId 、 Decimal 、 Date 、 Binaryの値を string として表します。 |
例
次の表は、このガイドの例で各出力形式を示すために使用されるサンプル ドキュメントのフィールドについて説明しています。 列は、各フィールドまたはネストされたフィールドのフィールド名、値、およびタイプを説明します。
名前 | 値 | タイプ | |
|---|---|---|---|
_id | | ObjectID ($oid) | |
w | | Array of: - Decimal128 ($numberDecimal)- Double ($numberDouble) | |
x | | Binary ($binary) | |
y | | Date ($date) | |
z | | Document with fields: - a: Boolean- b: Int32 ($numberInt)- c: String |
Default JSON Formatter
ソース コネクタの 構成プロパティ で、次のプロパティを設定して、デフォルトの JSON 形式を指定します。
"output.json.formatter": "com.mongodb.kafka.connect.source.json.formatter.DefaultJson"
Kafka トピックからサンプル ドキュメントの内容を出力すると、出力には次の型表現が表示されます。
ObjectId値（ BSON type の値）Decimal値（ BSON type の値）Binary値とそのバッファstringとバイナリ型DateUNIXエポックからのミリ秒単位
{ "_id": {"$oid": "5f15aab12435743f9bd126a4"}, "w": [{"$numberDecimal": "12345.6789"}, 23.53], "x": {"$binary": "SSBsb3ZlIGZvcm1hdHRpbmch", "$type": "00"}, "y": {"$date": 1683793627000}, "z": {"a": false, "b": 87, "c": "hello world"} }
拡張 JSON フォーマッタ
ソース コネクタの 構成プロパティ で、拡張 JSON 形式を指定するために次のプロパティを設定します。
"output.json.formatter": "com.mongodb.kafka.connect.source.json.formatter.ExtendedJson"
Kafka トピックからサンプル ドキュメントの内容を出力すると、出力には次の型表現が表示されます。
ObjectId値（ BSON type の値）Decimal値（ BSON type の値）Double値（ BSON type の値）Binary値とそのバッファstringとバイナリ型DateUNIXエポックからのミリ秒単位Int32値（ BSON type の値）
{ "_id": {"$oid": "5f15aab12435743f9bd126a4"}, "w": [{"$numberDecimal": "12345.6789"}, {"$numberDouble": "23.53"}], "x": {"$binary": "SSBsb3ZlIGZvcm1hdHRpbmch", "$type": "00"}, "y": {"$date": 1683793627000}, "z": {"a": false, "b": {"$numberInt": "87"}, "c": "hello world"} }
簡易 JSON フォーマッタ
ソース コネクタの構成プロパティで、次のプロパティを設定して、簡略化された JSON 形式を指定します。
"output.json.formatter": "com.mongodb.kafka.connect.source.json.formatter.SimplifiedJson"
Kafka トピックからサンプル ドキュメントの内容を出力すると、出力には次の型表現が表示されます。
ObjectId値を 16進数stringとしてDecimalstring としての値Binaryバッファstringとしての値Datestring としての値
{ "_id": "5f15aab12435743f9bd126a4", "w": ["12345.6789", 23.53], "x": "SSBsb3ZlIGZvcm1hdHRpbmch", "y": "2023-05-11T08:27:07Z", "z": {"a": false, "b": 87, "c": "hello world"} }