Criar um fluxo com um gatilho de mensagem do Kafka

Crie um fluxo que processa eventos de um fluxo do Kafka. Inicie o fluxo quando um evento estiver disponível no tópico especificado.

Antes de Iniciar

Função necessária: flow_designer ou administrador

Este gatilho faz parte de Stream Connect para Apache Kafka que requer uma assinatura Stream Connect para Apache Kafka. Para obter mais informações, consulte https://www.servicenow.com/products/automation-engine.html.

Este gatilho requer o plug-in ServiceNow Integration Hub Flow Trigger - Kafka [com.glide.hub.flow_trigger.kafka].

Procedimento

1. Navegar até Todos > Automação de Processo > Flow Designer.
2. Clicar Novo > Fluxo.
3. Defina as propriedades do fluxo.
   Para obter mais informações, consulte Criar um fluxo.
4. Na seção Gatilho, clique em Adicionar um gatilho e selecione Aplicação > Mensagem Kafka.
5. No formulário de mensagem do Kafka, preencha os campos.

   Campo	Descrição
   Tópico	Referência ao tópico para monitorar mensagens.
   Opções avançadas
   Iniciar processamento a partir de	Opção para iniciar o processamento de mensagens a partir do início ou do final da fila, organizadas por data. Selecione uma das seguintes opções. A mensagem mais antiga da fila: inicia o processamento a partir das mensagens mais antigas da fila. O fim da fila: inicia o processamento a partir das mensagens mais recentes da fila.
   Número de mensagens a serem processadas por execução	Opção para especificar o número de mensagens processadas por execução ou permitir que o sistema decida o número de mensagens. Selecione uma das seguintes opções. Otimizar automaticamente: o sistema determina o número de mensagens a serem processadas por execução. Substituição manual (avançado): você especifica o número de mensagens a serem processadas por execução.
   Insira o número de mensagens (ignorado se o valor gerado pelo sistema for menor)	Número de mensagens para processar cada execução. Este campo é exibido somente quando Número de mensagens a serem processadas por execução estiver definido como Substituir manualmente (avançado). Tipo: inteiro Valor padrão: 100 Valor mínimo: 1 Valor máximo: 100.000 Se o número selecionado for maior que o número calculado pelo sistema, o fluxo será executado com o número calculado pelo sistema. Dependendo do tamanho das mensagens, o número de mensagens processadas por execução pode ser menor do que o número especificado.

6. Clique em Concluído.
7. Opcional: Defina os campos Simultaneidade máxima e Peso relativo.
   O campo Simultaneidade máxima determina o número de grupos de partição a serem criados e o número de processadores paralelos a serem usados. O campo Peso relativo permite que você aloque mais tempo de processamento para o consumidor em relação a outros consumidores.
   1. Navegar até Todos > Automação de Processo > Administração do Fluxo > Configurações.
   2. No campo Fluxo/Subfluxo/Ação, selecione o ícone de ) para o fluxo e selecione Abrir registro.
   3. Selecione o ícone Ações ) e selecione Exibição > Kafka.
      O campo Simultaneidade máxima aparece no formulário.
   4. Para exibir o campo Ponderação relativa, selecione Avançado.
   5. Defina os valores de Simultaneidade máxima e Peso relativo.

      Campo	Descrição
      Simultaneidade máxima	Número máximo de processadores paralelos a serem usados para consumir mensagens e o número de grupos de partição a serem criados. Valor padrão: 1
      Peso relativo	Para cada ciclo, a quantidade máxima de tempo alocada ao consumidor para processar mensagens, em relação a outros consumidores. Por exemplo, um consumidor com um peso relativo que é o dobro do de outro consumidor recebe o dobro de tempo. Consumidores que têm o mesmo peso relativo obtêm a mesma quantidade de tempo. O valor mínimo é 5. O valor máximo é 2000. O valor padrão é igual à simultaneidade máxima multiplicada pelo valor da propriedade glide.ih.kafka.consumer.max_seconds_per_partition_group. A propriedade glide.ih.kafka.consumer.max_seconds_per_partition_group especifica o tempo máximo, em segundos, alocado para cada grupo de partição. Seu valor padrão é 10. O sistema usa o peso relativo para calcular o tempo limite do grupo de partições para a assinatura. O tempo limite do grupo de partições especifica o tempo máximo, em milissegundos, alocado para cada grupo de partições em uma assinatura específica. Este campo é exibido somente quando Avançado é selecionado.

   6. Selecione Atualizar.
   7. Navegue de volta para o fluxo em Flow Designer.
8. Adicione ações, subfluxos e lógica de fluxo ao fluxo.
9. Para testar o fluxo, clique no botão Testar.
   O botão Testar abre a caixa de diálogo Fluxo de teste, na qual você pode criar uma mensagem a ser enviada ao fluxo. O sistema testa o fluxo com esta mensagem recém-criada, não com mensagens do tópico do Kafka. O fluxo não começa a receber mensagens do tópico até que o fluxo seja ativado. Para obter mais informações, consulte Testar um fluxo.
10. Para ativar o fluxo, clique no botão Ativar.
    Quando você ativa o fluxo, o sistema começa a procurar mensagens no tópico. Você deve ativar o fluxo para receber mensagens. Para obter mais informações, consulte Ativar um fluxo.

Resultado

Quando há uma mensagem no tópico do Kafka, o fluxo é acionado e executa as ações.