Pular para o conteúdo principal

Kafka

Visão Geral​

O componente Kafka permite enviar mensagens para um tópico Kafka. Nesse cenário a integração se comporta como produtora de eventos. Caso deseje consumir mensagens de um tópico, utilize o Trigger Kafka.

Configuração​

Aqui estão os parâmetros gerais para a configuração do componente. Todos os parâmetros de campos de texto aceitam o uso de variáveis. Parâmetros que suportam expressões de template estão marcados com (Tmpl).

Informação adicional

O uso de variáveis em parâmetros de campos de texto é feito utilizando a expressão {{var.nome_da_variavel}}. Para saber mais sobre o uso de variáveis na criação de integrações, acesse a seção Canvas de integrações.

Alguns parâmetros suportam expressões de template para utilização de valores dinâmicos. Para saber mais sobre o funcionamento dessa linguagem e como utilizar expressões de template para referenciar dados para valores dinâmicos, acesse a seção Go Template de integrações.

Parâmetros​

  • ID do Componente: Obrigatório. Identificador do componente no fluxo de integração.
Informação adicional

Os IDs são únicos por fluxo. Não é possível ter mais de um componente com o mesmo ID.

O ID do Componente não pode conter espaços, deve iniciar com número e pode conter apenas letras sem acentos, números e o caractere _.

  • Nome: Rótulo opcional para identificar o componente visualmente no canvas.
  • Servidores: Obrigatório. Lista de servidores Kafka
  • Tópico (Tmpl): Obrigatório. Nome do tópico de destido
  • Partição (Tmpl): Obrigatório. Partição de destino
  • Mapeamento de entrada: Obrigatório. Mensagem que será enviada ao Kafka. O valor desde campo precisa obrigatoriamente ser o output de algum template já executado no fluxo. Ex: templateInputOut
  • Headers (Tmpl): Opcional. Adicione parametros que serão enviados no header do Kafka.

Saída​

Após a execução do componente, uma estrutura chave-valor será gerada com os dados de saída. Os dados podem ser acessados pelo contexto de execução em outros componentes em etapas posteriores do fluxo a partir da sintaxe .id_do_componenteOut.atributo_da_estrutura, onde:

  • id_do_componente: valor configurado do parâmetro ID do Componente
  • Out: sufixo padrão obrigatório
  • atributo_da_estrutura: atributo retornado na estrutura chave-valor de saída da execução do componente
Atenção!

Caso ocorra algum erro durante a execução do componente, a estrutura chave-valor de saída não é gerada.

Aqui estão os atributos gerais da estrutura de saída do componente:

  • msg: indicador de sucesso do envio da mensagem. Possui o valor fixo "ok".

Exemplo:

// ID do Componente: kafkaStep
{
  "kafkaStepOut": {
    "msg": "ok"
  }
}