Configurar um consumidor de script

  • Versão de lançamento: Yokohama
  • Atualizado 30 de jan. de 2025
  • 2 min. de leitura

    • Use um script para importar e processar dados do ambiente Kafka.

    Antes de Iniciar

    Por Que e Quando Desempenhar Esta Tarefa

    Para configurar um consumidor, você precisa criar dois registros.
    1. O registro do consumidor, que especifica como importar e processar dados.
    2. Um registro para o fluxo do Kafka, que define o fluxo de dados para o consumidor.
    Esta tarefa cobre a criação do consumidor. Para obter instruções sobre como criar um fluxo do Kafka, consulte Criar um fluxo do Kafka.

    Procedimento

    1. Navegar até Tudo > IntegrationHub > Consumidores > Consumidor de script.
    2. Selecione Novo.
    3. No formulário, preencha os campos.
      Tabela 1. Consumidor de script do Kafka
      Campo Descrição
      Nome Nome do consumidor de script.
      Garantia de entrega Se houver uma falha de nó, a opção para especificar a garantia de entrega para mensagens de entrada. Selecione uma das seguintes opções.
      • Não há mensagens perdidas, mas duplicadas: todas as mensagens são entregues pelo menos uma vez. Algumas mensagens podem ser entregues mais de uma vez.
      • Uma vez ou não: uma mensagem não é entregue mais de uma vez. Algumas mensagens podem não ser entregues.
      Formato de serialização O formato de serialização da mensagem. Selecione uma das seguintes opções.
      • Texto sem formatação: selecione esta opção para mensagens de texto sem formatação. Este é o formato padrão.
      • Codificado: selecione esta opção para mensagens em um formato Apache Avro. A conversão de mensagens de texto sem formatação para um formato Avro requer um esquema. Selecione o registro de esquema no campo Registro de esquema. Para obter mais informações sobre esquemas, consulte Gestão de esquemas no Stream Connect.
      Consumidor do evento Script a ser usado para consumir as mensagens recebidas do tópico Kafka.
      Aplicação Escopo da aplicação para o consumidor do mapa de transformação.
      Registro de esquema
      Registro do esquema selecionado. Selecione uma das seguintes opções.
      • Registro de esquema autônomo
      • Registro de esquema confluente

      Este campo aparece somente quando o formato de serialização está definido como codificado.

      Para o Registro de Esquema Confluente, se o ID do esquema da mensagem recebida não estiver na tabela de esquema, o sistema importará o esquema dinamicamente, usando a conexão REST configurada.
    4. Selecione Save (Salvar).

    Exemplo

    Este exemplo mostra um script de exemplo para processar mensagens.
    (function process(messages) {
 // Add your code here to consume kafka messages 
 // sample message [ { 'key' : 'message_key' , 'message' : 'message' , 'headers' : [ { 'key' : 'header_key' , 'value' : 'header_value' } ] } ] 

 for (var i = 0; i < messages.length; i++) {
     var message = JSON.parse(messages[i].message);
     gs.info('Number ' + message.number + ', short description ' + message.short_description +
         ', headers ' + JSON.stringify(messages[i].headers));
 }
})(messages);

    O que Fazer Depois

    Criar um fluxo do Kafka para este consumidor. Depois que o fluxo for ativado, você poderá começar a receber mensagens do seu ambiente Kafka.