Configurar um consumidor de script

Use um script para importar e processar dados do seu ambiente Kafka.

Antes de Iniciar

• Função necessária: integration_hub_admin
• Este consumidor faz parte de Stream Connect para Apache Kafka, que requer uma assinatura Stream Connect para Apache Kafka. Para obter mais informações, consulte https://www.servicenow.com/products/automation-engine.html.
• Os plug-ins a seguir são necessários.
  • O plug-in ServiceNow IntegrationHub Kafka Consumer (com.glide.hub.kafka_consumer).
  • O plug-in ServiceNow IntegrationHub ETL Consumer - Kafka (com.glide.hub.etl_consumer.kafka).

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 do Kafka, que define o fluxo de dados para o consumidor.

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

Procedimento

1. Navegar até Todos > IntegrationHub > Consumidores > Consumidor de script.
2. Selecione "Novo".
3. No formulário, preencha os campos.

   Tabela 1. Consumidor de script do Kafka

   Campo	Descrição
   Nome	Nome do consumidor de script.
   Garantia de entrega	Se houver uma falha de nó, opção para especificar a garantia de entrega das mensagens de entrada. Selecione uma das seguintes opções. Não há perdas, mas duplicatas: garante que todas as mensagens sejam entregues pelo menos uma vez. Algumas mensagens podem ser entregues mais de uma vez. Uma vez ou nunca: garante que uma mensagem não seja entregue mais de uma vez. Algumas mensagens podem não ser entregues.
   Consumidor de evento	Script a ser usado para consumir as mensagens recebidas do tópico do Kafka.
   Aplicação	Escopo da aplicação para o consumidor do mapa de transformação.

4. Selecione Salvar.

Exemplo

Este exemplo mostra um script de exemplo para processar mensagens.

(function process(messages) {
 // Add your code here to consume kafka messages 
 // sample message [ { 'key' : 'message_key' , 'message' : 'message' , 'headers' : [ { 'key' : 'header_key' , 'value' : 'header_value' } ] } ] 

 for (var i = 0; i < messages.length; i++) {
     var message = JSON.parse(messages[i].message);
     gs.info('Number ' + message.number + ', short description ' + message.short_description +
         ', headers ' + JSON.stringify(messages[i].headers));
 }
})(messages);

O que Fazer Depois

Criar um fluxo do Kafka para este consumidor. Depois que o fluxo for ativado, você poderá começar a receber mensagens do seu ambiente Kafka.