Use a etapa Produtor Kafka e a API ProducerV2 para publicar mensagens

Enviar dados de ServiceNowPara 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 o Hermes. Para configurar e testar sua conexão, consulte Configurar uma conexão segura com o Serviço de envio de mensagens Hermese. Testando a conexão com Hermes por meio do gateway ADCv2 .
• A primeira parte desta página mostra como usar a etapa Produtor Kafka em Workflow StudioPara 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 do 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. Inicie dois consumidores para receber 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 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 Kafka produtor etapa para a ação.

      Para adicionar uma etapa de ação, selecione o sinal de mais 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, vá para 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 de 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 de tópico.
   2. Para exibir a mensagem, vá para os consoles de linha de comando criados na etapa 1.
      A mensagem deve estar presente em um dos terminais.