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 requer uma assinatura Stream Connect. Para obter mais informações, consulte https://www.servicenow.com/products/automation-engine.html.

Este gatilho requer o plug-in ServiceNow Stream Connect Installer [com.glide.hub.stream_connect.installer].

Procedimento

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

   Campo	Descrição
   Tópico	Consulte o tópico para monitorar mensagens.
   Formato de serialização	O formato de serialização da mensagem. Selecione uma das seguintes opções. Texto sem formatação: selecione esta opção para mensagens de texto sem formatação. Este é o formato padrão. Codificado: selecione esta opção para mensagens em um formato Apache Avro. A conversão de mensagens de texto sem formatação para um formato Avro requer um esquema. Selecione o registro de esquema no campo Registro de esquema. Para obter informações sobre esquemas, consulte Schema management in Stream Connect.
   Registro de esquema	Registro do esquema selecionado. Selecione uma das seguintes opções. Registro de esquema autônomo Registro de esquema confluente Este campo aparece somente quando o formato de serialização está definido como codificado. Para o Registro de Esquema Confluente, se o ID do esquema da mensagem recebida não estiver na tabela de esquema, o sistema importará o esquema dinamicamente, usando a conexão REST configurada.
   Opções avançadas
   Iniciar processamento de	Opção para começar a processar mensagens a partir do início ou do fim da fila, organizadas por data. Selecione uma das seguintes opções. A mensagem mais antiga da fila: comece a processar a partir das mensagens mais antigas da fila. Fim da fila: inicie 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 sobre o número de mensagens. Selecione uma das seguintes opções. Otimização automática: o sistema determina o número de mensagens a serem processadas por execução. Substituir manualmente (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 aparece somente quando o Número de mensagens a serem processadas por execução está 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 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 inferior ao 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 alocar 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ção para a assinatura. O tempo limite do grupo de partição especifica o tempo máximo, em milissegundos, alocado para cada grupo de partição em uma assinatura específica. Este campo aparece somente quando Avançado está selecionado.

   6. Selecione Atualizar.
   7. Navegue de volta para o fluxo em Workflow Studio.
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 Testar fluxo, na qual você pode criar uma mensagem para enviar ao fluxo. O sistema testa o fluxo com esta mensagem recém-criada, não com mensagens do tópico 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 Kafka, o fluxo é acionado e executa as ações.