Use a etapa Produtor do Kafka e a API ProdutorV2 para publicar mensagens

Envie dados de ServiceNow para o Hermes para que os consumidores do Kafka possam lê-los.

Antes de Iniciar

• Função necessária: integration_hub_admin
• Esta página faz parte de 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 Set up a secure connection to the Hermes Messaging Service e Como testar a conexão com o Hermes por meio do gateway ADCv2.
• A primeira parte desta página mostra como usar a etapa do Produtor do Kafka em Workflow Studio para publicar mensagens no 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. Iniciar 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

      Certifique-se de substituir<instance name> com o nome da sua instância.
2. Publique mensagens da instância usando uma etapa de fluxo.
   1. Navegar até Todos > Automação de Processo > Flow Designer.
   2. Crie uma nova ação selecionando Criar novo > Ação.
   3. No formulário Propriedades da ação, dê um nome à ação e selecione Enviar.
      Este exemplo usa o nome Fornecedor de mensagem.
   4. Adicione uma etapa do Produtor do Kafka à ação.

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

      

   5. Na etapa, defina o campo Tópico como topic1.
   6. No campo Mensagem, insira uma mensagem.

      Você não precisa alterar nenhum outro campo.

      

   7. Selecione Salvar para salvar a ação.
   8. Selecione o botão Testar para testar a ação.
      O teste da 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 de scripts para publicar mensagens neste 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);
      

      Certifique-se de substituir<sys id of the topic record> 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.