/ /

出力形式のプロパティ

Overview

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

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

設定

名前

説明

output.format.key

タイプ: string

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

json
許容値:bson 、json 、schema

output.format.value

タイプ: string

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

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

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

タイプ: string

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

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

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

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

output.schema.value

タイプ: string

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

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

スタートアップ