Configure o. Apache Kafka Conector do consumidor

Configure o. Apache Kafka Instância do conector do consumidor para criar eventos a partir de mensagens de fluxo coletadas pelo Apache Kafka conector.

Antes de Iniciar

Certifique-se de que Gestão de eventos O plug-in Conectores (sn_em_connector) está instalado no ServiceNow AI Platform instância.

Função necessária: evt_mgmt_admin

Procedimento

1. Navegar até Tudo > Gestão de eventos > Integrações > Instâncias do conector.
2. Selecione Novo.
3. No formulário, preencha os campos.

   Tabela 1. Formulário de instância do conector

   Campo	Valor
   Nome	Nome descritivo e exclusivo do conector do consumidor Kafka.
   Descrição	Descrição a ser usada pela instância de coleta de eventos do consumidor Kafka.
   Definição do conector	Nome da definição do conector necessária, que, nesse caso, deve ser Consumidor do Kafka.
   IP do Host	O IP do host. Nota: Este campo deve conter um valor para concluir o processo de criação para que o espaço reservado 1.1.1.1 seja inserido como um valor temporário.
   Última execução da coleta de evento	Este campo é definido automaticamente com o último valor de tempo de execução.
   Status das últimas coletas de evento	Este campo é definido automaticamente com o último status de tempo de execução.
   Programações de coletas de evento (segundos)	A frequência em segundos que o sistema verifica se há novos eventos do consumidor Kafka. O valor padrão é 60 segundos.
   Última mensagem de erro	Este campo é definido automaticamente como a última mensagem de erro.

4. Para TEXTO SEM FORMATAÇÃO ou SASL_PLAINTEXT, em Credencial Crie uma credencial de autenticação básica.
   Use Credencial SSL do Kafka Digite para uma nova instância do conector de extração do Kafka com SASL_TEXTO SEM FORMATAÇÃO autenticação. Vá para a etapa 5.

   Usar . Credencial SSL do Kafka Quando o servidor Kafka for sasl.habilitado.mecanismos ou mecanismo.sasl o valor do parâmetro não é igual SIMPLES . Vá para a etapa 5.

   1. Selecione o ícone Pesquisar ao lado de Credencial campo.
   2. Na tela Credenciais, selecione Novo .
   3. Na lista de credenciais disponíveis, selecione Credenciais de autenticação básica .
   4. Na tela Autenticação básica, forneça informações para autenticação de TEXTO SEM FORMATAÇÃO, que não requer credenciais, ou autenticação SASL_TEXTO SEM FORMATAÇÃO, que requer credenciais.
      • Para autenticação EM TEXTO SEM FORMATAÇÃO, no Nome digite qualquer valor e saia de Nome de usuário e. Senha campos vazios.
      • Para autenticação SASL_PLAINTEXT, forneça um nome para a credencial no Nome campo, de preferência precedido por SASL . Forneça o nome de usuário e a senha no Nome de usuário e. Senha campos.
   5. Selecione Enviar.
5. Para uma credencial de autenticação SASL_PLAINTEXT, SSL ou SASL_ssl, no Credencial Crie uma credencial SSL Kafka.
   1. Selecione o ícone Pesquisar ao lado de Credencial campo.
   2. Na tela Credenciais, selecione Novo .
   3. Na lista de credenciais disponíveis, selecione Credenciais SSL do Kafka .
   4. Na tela Autenticação SSL do Kafka, preencha os campos Credenciais SSL do Kafka.
      Para obter as descrições dos campos de credenciais SSL do Kafka, consulte .

      Nota:

      Se você limpar Desabilitar verificação de nome de host e, em seguida, em Propriedades adicionais do consumidor Kafka , insira o valor de ssl.endpoint.identification.algorithmParâmetro igual ao valor do parâmetro do servidor Kafka. Por exemplo:

      ssl.enabled.protocols=TLSv1.2,TLSv1.1,TLSv1;
      sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username=<username> password=<password>;
      sasl.enabled.mechanisms=PLAIN;ssl.endpoint.identification.algorithm=;

   5. Selecione Enviar.
6. Clique com o botão direito no cabeçalho do formulário e selecione Salvar.
7. Na tabela que apresenta os valores da instância do conector, verifique os valores da instância do conector preenchidos com base na configuração do Kafka e na mensagem (carga JSON) que você recebeu do tópico do Kafka.

   Se necessário, altere os valores da instância do conector.

   Tabela 2. Tabela de valores da instância do conector

   Campo	Descrição
   authentication_type	O tipo de autenticação do consumidor Kafka. Os valores compatíveis atualmente são: TEXTO SEM FORMATAÇÃO (sem autenticação) (padrão) SASL_PLAINTEXT (autenticação básica – nome de usuário e senha)
   bootstrap_servers	Os servidores que estabelecem a conexão com o cluster Kafka. Os valores neste campo devem estar no formato host1:port1, host2:port2 e assim por diante (separados por vírgulas). Este campo é obrigatório.
   consumer_group_name	O nome do grupo Consumidor. Se o mesmo tópico do Kafka estiver sendo consumido de duas instâncias diferentes, use nomes de grupo de consumidores diferentes para que todos os eventos sejam capturados para ambas as instâncias. Este campo é obrigatório.
   time_of_event_field	O nome do campo na carga/mensagem JSON que inclui a hora do evento. Se um campo na carga/mensagem JSON incluir a hora do evento, esse valor deverá ser o valor desse parâmetro. Se nenhum valor de campo de tempo for fornecido, a hora de recebimento do evento no ServiceNow a instância está definida como time_of_event. O campo time_of_event deve ser um campo de primeiro nível na carga/mensagem JSON. Nomes de campos aninhados não são permitidos.
   fuso horário	O fuso horário do campo time_of_event na carga/mensagem JSON. O valor do fuso horário não é usado quando o campo time_of_event está vazio. Por exemplo, se time_of_event na carga/mensagem estiver no fuso horário IST, o valor será GMT 0530. Padrão: GMT.
   date_format	Formato date_time do campo time_of_event na carga/mensagem JSON. Se nenhum valor de campo de tempo for fornecido, a hora em que o evento foi recebido na instância no horário GMT será usada. O valor date_time não é usado quando o campo time_of_event está vazio. Padrão: aaaa-MM-dd HH:mm:sss.
   depurar	Exibe mensagens de depuração. Valor padrão: Falso. Especifique verdadeiro para ver mensagens de depuração.
   logPayloadForDebug	Exibe mensagens de depuração relacionadas à carga. Valor padrão: Falso. Especifique verdadeiro para ver mensagens de depuração relacionadas à carga.
   tópico	O tópico do Kafka do qual as mensagens são obtidas. Este campo é obrigatório.

8. Em MID Servers para conectores especifique um MID Server que está ativo e é válido.
   Nota:

   Você pode configurar vários MID Servers. Se o primeiro servidor estiver inativo, o próximo MID Serveré usado. Se for isso MID Server não está disponível, o próximo está selecionado e assim por diante. MID Servers são classificados de acordo com a ordem em que seus detalhes foram inseridos MID Servers para conectores seção.

   Se você não especificar um MID Server disponível MID Server Que tem um intervalo de IPs correspondente é usado.

9. Clique com o botão direito no cabeçalho do formulário e selecione Salvar.
10. Teste a conexão entre o. MID Server E o conector do consumidor Kafka.
    1. Selecione Conector de teste .
    2. Se a conexão de teste falhar, verifique se a credencial é válida e se a rede está conectada do MID Server Para o agente Kafka.
       Nota:

       A validação de nome de tópico do Kafka ocorre somente em Conector de teste validação.
11. Após um teste bem-sucedido, ative a instância do conector selecionando Ativo caixa de seleção.
12. Selecione Atualização botão.

O que Fazer Depois

Depois que o conector é criado, você deve mapear os campos. Para obter mais informações, consulte Mapeie atributos de carga de mensagem do Kafka para campos de alerta.