Use o gatilho Mensagem Kafka e o consumidor de script para consumir mensagens

  • Versão de lançamento: Zurich
  • Atualizado 31 de jul. de 2025
  • 3 min. de leitura

    • Recupere mensagens do Hermes com o gatilho Mensagem do Kafka em Workflow Studio E o consumidor Script.

    Antes de Iniciar

    Procedimento

    1. Crie um tópico para consumir mensagens.
      1. Use o comando a seguir para criar um tópico no Hermes. 
        bin/kafka-topics.sh --create --command-config config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002, <instance name>.service-now.com:4003 --topic snc.<instance name>.topic1
        Substitua <instance name> com o nome da sua instância.
      2. Para exibir o tópico, faça login na instância e navegue até Tudo > IntegrationHub > Conexão de fluxo > Tópicos.
        Nota:
        Leva aproximadamente 10 minutos para criar um tópico.
    2. Crie um gatilho de fluxo para consumir mensagens do tópico.
      1. Navegar até Tudo > Automação de Processo > Flow Designer.
      2. Selecionar Criar novo > Fluxo.
      3. No formulário Propriedades de fluxo, insira um nome para o fluxo e insira Enviar .
        Este exemplo usa o nome Topic1 consumidor .
      4. Na seção do gatilho, selecione Adicione um gatilho e selecione Mensagem do Kafka como o tipo de gatilho.
        Mensagem do Kafka é o tipo de gatilho para o fluxo.
      5. Selecione o tópico Topic1.
        Selecione tópico 1 para o campo Tópico.

        Você pode usar o ícone de lupa para ver a lista de tópicos disponíveis.

      6. Na seção Ações do fluxo, navegue até Adicionar uma Ação, Lógica de Fluxo ou Subfluxo > Lógica de fluxo > For Each.
      7. Arraste Mensagens cápsula de dados para Itens e selecione Concluído .
      8. Na seção Ações do fluxo, navegue até Adicionar uma Ação, Lógica de Fluxo ou Subfluxo > Ação > ServiceNow Core > Log.
      9. Arraste Carga cápsula de dados para Mensagem e selecione Concluído .
        Gatilho de fluxo do consumidor de Topic1.
      10. Salvar o gatilho de fluxo.
      11. Vá para a tabela Configurações [sys_flow_execution_setting] para habilitar a emissão de relatórios para este fluxo.
      12. Crie uma nova entrada e habilite a emissão de relatórios para o fluxo criado acima.
        Criação de um novo registro de configuração para habilitar a emissão de relatórios para o fluxo.
      13. Navegue de volta para seu fluxo e selecione Ativar .
      14. Para exibir sua assinatura de tópico, navegue até Tudo > Hub de integração > Conexão de fluxo > Assinaturas.
        A assinatura do tópico topic1.
    3. Publique mensagens no tópico usando a ferramenta de linha de comando Kafka.
      1. Execute o comando a seguir para publicar mensagens no tópico. 
        bin/kafka-console-producer.sh --topic snc.<instance name>.topic1  --producer.config  config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002,<instance name>.service-now.com:4003

        Substitua <instance name> com o nome da sua instância.

        Este comando solicita mensagens. Adicione algumas mensagens de amostra. Este exemplo usa as seguintes mensagens.
        • mensagem de teste 1
        • Mensagem de teste 2
        • Mensagem de teste 3
        Você deve receber as mensagens em cerca de um minuto.
      2. Navegue de volta para o fluxo e selecione Execuções .
        Selecione Execuções para navegar até a exibição de execução do fluxo.
      3. Abra a execução do fluxo.
        Detalhes da execução do fluxo.
      4. Para exibir as estatísticas desta assinatura, navegue até Tudo > Hub de integração > Conexão de fluxo > Assinaturasabra a assinatura e vá para a exibição de estatísticas.
        As estatísticas do Kafka para a assinatura.
    4. Crie um consumidor de script para consumir mensagens do tópico.
      1. Navegar até IntegrationHub > Consumidores > Consumidores de script.
      2. Selecione Novo.
      3. Em Nome , insira um nome para o consumidor de script.
        Este exemplo usa Topic1 consumidor .
      4. Defina o script para registrar a mensagem adicionando a seguinte lógica na caixa de script. 
        for (var i = 0; i < messages.length; i++) {
      gs.info('Received message ' + JSON.stringify(messages[i].message));
 }
        Consumidor de script do Kafka mostrando o script no campo Consumidor de evento.
      5. Salve o formulário.
      6. Na seção Links relacionados, selecione Novo Para adicionar um fluxo Kafka para consumir as mensagens.
      7. No formulário Fluxo do Kafka, defina os seguintes valores de campo.
        • Nome . Fluxo de Topic1 .
        • Tópico para o tópico criado anteriormente, tópico 1.
        • Simultaneidade máxima . 1 .
        • Comece a consumir . Todas as mensagens armazenadas no tópico . Esta opção permite que você leia as mensagens já publicadas neste tópico.
        • Tratamento de mensagens . Otimizar automaticamente .
        O registro Kafka Stream.
      8. Selecione Ativar Link em Links relacionados.
        Você deve ser capaz de ver a assinatura ativada.
      9. Para exibir as mensagens, navegue até Tudo > Logs do sistema > Log do sistema E filtram mensagens que começam com a mensagem recebida.
        Lista de mensagens recebidas.
      10. Todas as mensagens devem ser exibidas após 1 minuto.

    O que Fazer Depois

    Use os consumidores de ETL e Mapa de transformação para importar dados.