Configure um consumidor de mapa de transformação

Importe e processe dados do seu ambiente Kafka usando as configurações de mapa de transformação existentes.

Antes de Iniciar

• Função necessária: Integration_hub_admin
• Este consumidor requer um Stream Connect assinatura. Para obter mais informações, consulte https://www.servicenow.com/now-platform/workflow-data-fabric.html.
• . ServiceNow O plug-in do Stream Connect Installer [com.glide.hub.stream_connect.installer] é necessário.
• Este consumidor requer um mapa de transformação .

Formatando cargas úteis de mensagens do Kafka

Use cargas JSON simples para mensagens do Kafka. Cada mensagem do Kafka deve ter apenas um objeto JSON simples. Cargas JSON complexas, como aquelas com listas e objetos aninhados, não são compatíveis.

Exemplo de entrada JSON simples e válida, usando um mapa plano de pares de chave-valor.

{"key1": "value1", "key2": "value2"}

Exemplos de entrada JSON complexa e inválida. O primeiro usa uma lista. O segundo usa objetos aninhados.

[{"key1": "value1", "key2": "value2"}, {"key1": "value3", "key2": "value4"}]

{"key1": "value1", "key2": {"key3": "value3", "key4": "value4"}}

Por Que e Quando Desempenhar Esta Tarefa

Para configurar um consumidor, você precisa criar dois registros.

1. O registro do consumidor, que especifica como importar e processar dados.
2. Um registro para o fluxo Kafka, que define o fluxo de dados para seu consumidor.

Esta tarefa cobre a criação do consumidor. Para obter instruções sobre como criar um fluxo Kafka, consulte Crie um fluxo Kafka.

Procedimento

1. Navegar até Tudo > IntegrationHub > Consumidores > Consumidor de mapa de transformação.
2. Selecione Novo.
3. No formulário, preencha os campos.

   Tabela 1. Consumidor de mapa de transformação

   Campo	Descrição
   Nome	Nome do consumidor do mapa de transformação.
   Mapa de Transformação	Nome do mapa de transformação a ser usado para processar dados.
   Garantia de entrega	Se houver uma falha de nó, opção para especificar a garantia de entrega para mensagens de entrada. Selecione uma das seguintes opções. Não perdidos, mas duplicados : Todas as mensagens são entregues pelo menos uma vez. Algumas mensagens podem ser entregues mais de uma vez. Uma vez ou não : Uma mensagem não é entregue mais de uma vez. Algumas mensagens podem não ser entregues.
   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 mais informações sobre esquemas, consulte Gestão de esquemas em Stream Connect.
   Mapeamento de coluna	Opção para especificar se a chave JSON da mensagem mapeia os dados para o nome ou rótulo da coluna na tabela do conjunto de importação. Selecione uma das seguintes opções. Rótulo Nome da coluna
   Sincronizar inserções	Opção para garantir que haja apenas um registro com valores de campo exclusivos aglutinar valores de campo sincronizando inserções de registro.
   Aplicação	Escopo da aplicação para o consumidor do mapa de transformação.
   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.

4. Selecione Save (Salvar).

O que Fazer Depois

Crie um fluxo Kafka para este consumidor. Depois que o fluxo é ativado, você pode começar a receber mensagens do seu ambiente Kafka.