Use a etapa do produtor Kafka e a API do ProducerV2 para publicar mensagens

Enviar dados de ServiceNow Hermes para que os consumidores Kafka possam lê-los.

Antes de Iniciar

• Função necessária: Integration_hub_admin
• Esta página faz parte do Stream Connect guia de início rápido.
• Este documento mostra como publicar mensagens por meio de sua conexão com Hermes. Para configurar e testar sua conexão, consulte Configurar uma conexão segura com o Serviço de envio de mensagens Hermes e. Testando a conexão com Hermes por meio do gateway ADCv2 .
• A primeira parte desta página mostra como usar a etapa Produtor do Kafka no Workflow Studio Para publicar mensagens para Hermes. Para obter mais informações sobre a etapa, consulte Kafka Producer step.
• A segunda parte desta página mostra como usar a API ProducerV2 para publicar mensagens. Para obter mais informações, consulte API ProducerV2 .
• Para receber todas as mensagens, você precisa executar dois consumidores para datacenters diferentes. Consulte Consume test messages from a Hermes topic using the Kafka client para obter detalhes.

Procedimento

1. Faça com que dois consumidores recebam mensagens.
   1. Execute os seguintes comandos na linha de comando para receber as mensagens.

      bin/kafka-console-consumer.sh --consumer.config config/bootcamp.properties --topic snc.<instance name>.topic1 --group snc.<instance name>.consumer_group1 --from-beginning --bootstrap-server <instance name>.service-now.com:4100,<instance name>.service-now.com:4101,<instance name>.service-now.com:4102,<instance name>.service-now.com:4103

      bin/kafka-console-consumer.sh --consumer.config config/bootcamp.properties --topic snc.<instance name>.topic1 --group snc.<instance name>.consumer_group1 --from-beginning --bootstrap-server <instance name>.service-now.com:4200, <instance name>.service-now.com:4201, <instance name>.service-now.com:4202, <instance name>.service-now.com:4203

      Substitua <instance name> com o nome da sua instância.
2. Publique mensagens da instância usando uma etapa de fluxo.
   1. Navegar até Tudo > Automação de Processo > Flow Designer.
   2. Selecione para criar uma nova ação Criar novo > Ação.
   3. No formulário Propriedades da ação, atribua um nome à ação e selecione Enviar .
      Este exemplo usa o nome Fornecedor de mensagens.
   4. Adicione um Produtor do Kafka vá para a ação.

      Para adicionar uma etapa de ação, selecione o sinal de adição entre Entradas e. Avaliação de erro Na Descrição da ação.

      

   5. Na etapa, defina Tópico campo para tópico 1 .
   6. Em Mensagem , insira uma mensagem.

      Você não precisa mudar nenhum outro campo.

      

   7. Selecione Salvar para salvar a ação.
   8. Selecione Teste botão para testar a ação.
      Testar a ação publica a mensagem no tópico.
   9. Para exibir a mensagem, acesse os consoles de linha de comando criados na etapa 1.
      A mensagem deve estar presente em um dos terminais.
3. Publique mensagens da instância usando um script.
   1. Execute o script a seguir usando o plano de fundo dos scripts para publicar mensagens para este tópico da instância.

      var producer = new sn_ih_kafka.ProducerV2();
      producer.send('<sys id of the topic record>', gs.generateGUID(), 'Test message from ServiceNow', false, null);
      

      Substitua sys id do registro de tópico> com o sys_id do registro do tópico.
   2. Para exibir a mensagem, acesse os consoles de linha de comando criados na etapa 1.
      A mensagem deve estar presente em um dos terminais.