出力形式のプロパティ

Overview

次の構成設定を使用して、MongoDB Kafka ソースコネクタが Kafka トピックに公開するデータの形式を指定します。

カテゴリ別に整理されたソースコネクタ構成設定のリストについては、「ソースConnector構成プロパティ」に関するガイドを参照してください。

設定

名前

説明

output.format.key

型: string

説明:
ソースコネクタがキードキュメントを出力するデータ形式を指定します。

デフォルト: json
許容値: bson, json, schema

output.format.value

型: string

説明:
ソースコネクタが値ドキュメントを出力するデータ形式を指定します。

コネクタは、出力データ形式としてProtobufをサポートしています。値を指定し、 Kafka Connect Protobuf Converter をインストールして構成することで、この形式を有効にできます。schema

デフォルト: json
許容値: bson、json、schema

output.json.formatter

型: string

説明:
コネクタがデータを出力するために使用するJSONフォーマッタのクラス名。

デフォルト:

com.mongodb.kafka.connect.source.json.formatter.DefaultJson

許容値:
カスタム JSON フォーマッターの完全クラス名または、次のいずれかの組み込みフォーマッタークラス名:

com.mongodb.kafka.connect.source.json.formatter.DefaultJson
com.mongodb.kafka.connect.source.json.formatter.ExtendedJson
com.mongodb.kafka.connect.source.json.formatter.SimplifiedJson

これらの出力形式の詳細については、「 JSON フォーマッタ」を参照してください。

output.schema.key

Type: string

説明:
SourceRecordのキードキュメントのAvroスキーマ定義を指定します。

Avroスキーマの詳細については、 Data 形式ガイドの Avro を参照してください。

デフォルト:

{
  "type": "record",
  "name": "keySchema",
  "fields" : [ { "name": "_id", "type": "string" } ]"
}

許容値: 有効な Avro スキーマ

output.schema.value

Type: string

説明:
SourceRecordの値ドキュメントのAvroスキーマ定義を指定します。

Avroスキーマの詳細については、データ形式ガイドの Avro を参照してください。

デフォルト:

{
  "name": "ChangeStream",
  "type": "record",
  "fields": [
    { "name": "_id", "type": "string" },
    { "name": "operationType", "type": ["string", "null"] },
    { "name": "fullDocument", "type": ["string", "null"] },
    { "name": "ns",
      "type": [{"name": "ns", "type": "record", "fields": [
                {"name": "db", "type": "string"},
                {"name": "coll", "type": ["string", "null"] } ]
               }, "null" ] },
    { "name": "to",
      "type": [{"name": "to", "type": "record",  "fields": [
                {"name": "db", "type": "string"},
                {"name": "coll", "type": ["string", "null"] } ]
               }, "null" ] },
    { "name": "documentKey", "type": ["string", "null"] },
    { "name": "updateDescription",
      "type": [{"name": "updateDescription",  "type": "record", "fields": [
                 {"name": "updatedFields", "type": ["string", "null"]},
                 {"name": "removedFields",
                  "type": [{"type": "array", "items": "string"}, "null"]
                  }] }, "null"] },
    { "name": "clusterTime", "type": ["string", "null"] },
    { "name": "txnNumber", "type": ["long", "null"]},
    { "name": "lsid", "type": [{"name": "lsid", "type": "record",
               "fields": [ {"name": "id", "type": "string"},
                             {"name": "uid", "type": "string"}] }, "null"] }
  ]
}

許容値: 有効な JSON schema

output.schema.infer.value

タイプ: ブール値

説明:
コネクタが SourceRecord の値ドキュメントのスキーマを推論するかどうか。コネクタは各ドキュメントを分離して処理するため、コネクタは多くのスキーマを生成する可能性があります。

重要: コネクタは、output.format.value 設定を schema に設定した場合にのみ、この設定を読み取ります。

デフォルト: false
許容値: true または false

戻る

ChangeStream

スタートアップ