Configure o. Apache KafkaConector do consumidor

Configure o. Apache KafkaInstância do conector do consumidor para criar eventos a partir de mensagens de streaming coletadas pelo Apache Kafkaconector.

Antes de Iniciar

Certifique-se de que Gestão de eventosO plug-in Conectores (sn_em_connector) está instalado no Now Platforminstâ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 de conector necessária, que, neste caso, deve ser Consumidor 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 da última coleta de métrica	Este campo é definido automaticamente com o último status de tempo de execução.
   Programação de coleta 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_TEXTO SEM FORMATAÇÃO, no Credencial Crie uma credencial de autenticação básica.
   Use o. Credencial SSL do Kafka Digite para uma nova instância do conector de extração Kafka com TEXTO SIMPLES autenticação. Vá para a etapa 5.

   Uso . Credencial SSL do Kafka Digite quando o servidor Kafka for mecanismos.sasl.habilitado 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ásicas .
   4. Na tela Autenticação básica, forneça informações para autenticação de TEXTO SIMPLES, que não requer credenciais, ou autenticação SASL_TEXTO SIMPLES, que requer credenciais.
      • Para autenticação EM TEXTO SIMPLES, no Nome digite qualquer valor e deixe o. Nome de usuário e. Senha campos vazios.
      • Para autenticação SASL_PLAINTEXT, dê 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 do Kafka SSL, preencha os campos Credenciais do Kafka SSL.
      Para obter as descrições dos campos de credenciais do Kafka SSL, consulte .

      Nota:

      Se você limpar Desabilite a verificação do nome do 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 no momento são: TEXTO SIMPLES (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 do 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 ServiceNowa 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	O formato date_time do campo time_of_event na carga/mensagem JSON. Se nenhum valor de campo de hora 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 Serverque 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 Servernão está disponível, o próximo está selecionado e assim por diante. MID Serverssã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, um disponível MID ServerQue 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 ServerE 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 a partir do MID ServerPara o agente Kafka.
       Nota:

       A validação do nome do 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 Atualizar botão.

O que Fazer Depois

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