Crie um fluxo com um gatilho Mensagem 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 um Stream Connect assinatura. Para obter mais informações, consulte https://www.servicenow.com/now-platform/workflow-data-fabric.html.

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

Procedimento

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

   Campo	Descrição
   Tópico	Referência ao 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 qualquer mensagem de texto sem formatação. Este é o formato padrão. Codificado : Selecione esta opção para mensagens em um Apache Formato Avro. Converter mensagens de texto sem formatação para um formato Avro requer um esquema. Selecione o registro de esquema no Registro de esquema campo. 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 confluent Este campo aparece somente quando Formato de serialização está definido como Codificado . Para o Registro de esquema confluent, se o ID de 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 do início ou do final da fila, organizadas por data. Selecione uma das seguintes opções. A mensagem mais antiga na fila : Iniciar o processamento das mensagens mais antigas na fila. O fim da fila : Iniciar o processamento das mensagens mais recentes na 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. 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 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 do 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 Simultaneidade máxima e. Peso relativo campos.
   . Simultaneidade máxima o campo determina o número de grupos de partição a serem criados e o número de processadores paralelos a serem usados. . Peso relativo o campo permite alocar mais tempo de processamento para o consumidor em relação a outros consumidores.
   1. Navegar até Tudo > Automação de Processo > Administração do Fluxo > Configurações.
   2. Em Subfluxo/Ação , selecione o ícone de informações ( ) para o fluxo e selecione Registro em aberto .
   3. Selecione o ícone Ações adicionais ( ) e selecione Exibição > Kafka.
      . Simultaneidade máxima o campo aparece no formulário.
   4. Para exibir o. Peso relativo campo, selecione Avançado .
   5. Defina os valores para 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 duas vezes maior que o de outro consumidor recebe o dobro do tempo. Os consumidores que têm o mesmo peso relativo tê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 de glide.ih.kafka.consumer.max_seconds_per_partition_grouppropriedade. . glide.ih.kafka.consumer.max_seconds_per_partition_groupa propriedade especifica o tempo máximo, em segundos, alocado para cada grupo de partições. 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 aparece somente quando Avançado selecionado.

   6. Selecione Atualizar.
   7. Navegue de volta para seu fluxo em Workflow Studio.
8. Adicione ações, subfluxos e lógica de fluxo ao fluxo.
9. Para testar o fluxo, clique em Teste botão.
   . Teste Abre a caixa de diálogo Fluxo de teste, na qual você pode criar uma mensagem para enviar para o 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 em Ativar botão.
    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 aciona e executa as ações.