/ /

Conector de origem

Propriedades de configuração

Página inicial do Docs

Ferramentas

Conector Kafka

Conector de origem

Propriedades de configuração

Propriedades do Formato de Saída

Visão geral

Use as seguintes definições de configuração para especificar o formato dos dados que o conector de origem MongoDB Kafka publica nos tópicos do Kafka.

Para obter uma lista de definições de configuração do conector de origem organizadas por categoria, consulte o guia sobre Propriedades de configuração do conector de origem.

Configurações

Nome

Descrição

output.format.key

Tipo: string

Descrição:
especifica qual formato de dados o conector de origem produz o documento de chave.

Padrão: json
Valores bsonaceitos:,, jsonschema

output.format.value

Tipo: string

Descrição:
especifica em qual formato de dados o conector de origem gera o documento de valor.

O conector é compatível com Protobuf como um formato de dados de saída. Você pode habilitar este formato especificando o schema valor do e instalando e configurando o Conversor de Protobuf do Kafka Connect.

Padrão: json
Valores aceitos:,, bsonjsonschema

output.json.formatter

Tipo: string

Descrição:
nome de classe do formatador JSON que o conector deve usar para produzir dados.

Padrão:

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

Valores aceitos:
seu nome de classe completo do formatador JSON personalizado ou um dos seguintes nomes de classe do formatador integrado:

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 saber mais sobre esses formatos de saída, consulte Formatadores JSON.

output.schema.key

Tipo: string

Descrição:
especifica uma definição de esquema

Avro para o documento de chave do SourceRecord. Para saber mais sobre o esquema Avro, consulte Avro no guia Formatos de Dados.

Padrão:

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

Valores aceitos: um esquema Avro válido

output.schema.value

Tipo: string

Descrição:
especifica uma definição de esquema

Avro para o documento de valor do SourceRecord. Para saber mais sobre o esquema Avro, consulte Avro no guia Formatos de Dados.

Padrão:

{
  "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 aceitos: um JSON schema válido

output.schema.infer.value

Tipo: booleano

Descrição:
Se o conector deve inferir o esquema para o documento de valor do SourceRecord. Como o conector processa cada documento isoladamente, o conector pode gerar muitos esquemas.

IMPORTANTE: o conector só lê essa configuração quando você define a output.format.value configuração schema como.

Padrão: false
Valores aceitos: true ou false

Voltar

Change stream

Inicialização