/ /

Connector de origen

Propiedades de configuración

Propiedades de configuración

Propiedades del formato de salida

Overview

Usa la siguiente configuración para especificar el formato de los datos que el conector fuente MongoDB Kafka publica en los temas de Kafka.

Para obtener una lista de la configuración del origen del conector organizadas por categoría, consulta la guía Propiedades de configuración del conector de origen.

Configuraciones

Nombre

Descripción

output.formato.key

Tipo: cadena

Descripción:
Especifica el formato de datos en el que el conector de origen genera el documento clave.

json
Valor predeterminado: Valoresbson jsonaceptados:,, schema

output.format.value

Tipo: cadena

Descripción:
Especifica el formato de datos en el que el conector de origen genera el documento de valor.

El conector admite Protobuf como formato de datos de salida. Puede habilitar este formato especificando el schema valor e instalando y configurando el convertidor de Protobuf de Kafka Connect.

json
Valor predeterminado: Valores aceptados:,, bsonjsonschema

output.json.formatter

Tipo: cadena

Descripción:
Nombre de la clase del formateador JSON que el conector debe usar para generar datos.

Predeterminado:

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

Valores aceptados:
El nombre completo de la clase de su formateador JSON personalizado o uno de los siguientes nombres de clases de formateadores integrados:

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

Para aprender más sobre estos formatos de salida, consulta Formateadores JSON.

output.esquema.key

Tipo: cadena

Descripción:
Especifica una definición de esquema Avro para el documento clave del SourceRecord.

Para obtener más información sobre el esquema Avro, consulte Avro en la guía de formatos de datos.

Predeterminado:

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

Valores aceptados: Un esquema Avro válido

output.esquema.value

Tipo: cadena

Descripción:
Especifica una definición de esquema

Avro para el documento de valor del SourceRecord. Para obtener más información sobre el esquema Avro, consulte Avro en la guía de formatos de datos.

Predeterminado:

{
  "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"] }
  ]
}

Valores aceptados: un JSON schema válido

esquema.infer.valor

Tipo: booleano

Descripción:
Indica si el conector debe inferir el esquema para el documento de valor del SourceRecord. Dado que el conector procesa cada documento de forma aislada, puede generar varios esquemas.

IMPORTANTE: El conector solo lee esta configuración cuando se establece el output.format.value valor schema en.

false
Valor predeterminado: Valores aceptados: true o false

Volver

ChangeStream

Startup