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

Envie dados de ServiceNow para a 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 do Stream Connect para Apache Kafka guia de início rápido.
• Este documento mostra como publicar mensagens por meio de sua conexão com a Hermes. Para configurar e testar sua conexão, consulte Set up a secure connection to the Hermes Messaging Service e Testando a conexão com a Hermes por meio do gateway ADCv2.
• A primeira parte desta página mostra como usar a etapa Produtor do Kafka em Flow Designer para publicar mensagens na 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 mais 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

      Certifique-se de substituir<instance name> pelo 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 Editor 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 no Contorno da ação.

      

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

      Você não precisa mudar nenhum outro campo.

      

   7. Selecione Salvar para salvar a ação.
   8. Selecione o botão Testar 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 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, vá para os consoles de linha de comando criados na etapa 1.
      A mensagem deve estar presente em um dos terminais.