ProdutorV2 - Com escopo

A API ProducerV2 fornece métodos para publicar mensagens da sua instância ServiceNow em um tópico do Kafka.

Nota:

Esta API requer uma assinatura Stream Connect. Para obter mais informações, consulte https://www.servicenow.com/products/automation-engine.html.

Esta API requer o plug-in ServiceNow Stream Connect Installer (com.glide.hub.stream_connect.installer) e é executada no namespace sn_ih_kafka.

ProdutorV2 - send(cadeia de caracteres topicSysID, chave de cadeia de caracteres, mensagem de cadeia de caracteres, booliano isSync, cabeçalhos de objeto, esquemaID de cadeia de caracteres)

Envia a mensagem especificada para o tópico Kafka especificado.

Tabela 1. Parâmetros

Nome	Tipo	Descrição
topicSysID	Cadeia de caracteres	Sys_id do tópico no qual a mensagem será publicada. Os tópicos são armazenados na tabela Tópicos Kafka [sys_kafka_topic].
chave	Cadeia de caracteres	Nome da chave para uma partição específica no tópico.
mensagem	Cadeia de caracteres	Texto da mensagem.
estáSincronizado	Booliano	Sinalizador que indica se o script deve aguardar a conclusão do método de envio antes de continuar. Valores válidos: verdadeiro: aguarde a conclusão da etapa antes de continuar o fluxo associado. falso: não espere a etapa ser concluída antes de continuar o fluxo associado.
cabeçalhos	Objeto	Cabeçalhos da mensagem, definidos como pares de chave-valor. "headers": { "<key>": "<value>" } Por exemplo, var headers = { "origin": "sn_business_rule" }; chave: cadeia de caracteres. Nome do cabeçalho. valor: cadeia de caracteres. Valor do cabeçalho.
ID do esquema	Cadeia de caracteres	Sys_id do registro do esquema. Obrigatório se você estiver usando um esquema para converter mensagens de texto sem formatação em mensagens Avro e vice-versa. Os esquemas são armazenados na tabela Esquemas de conexão de fluxo [stream_connect_schema]. Para obter mais informações, consulte Schema management in Stream Connect.

Tabela 2. Retorna

Tipo	Descrição
Nenhum(a)

Este exemplo mostra como enviar informações de incidentes alteradas para o tópico Kafka com um sys_id de 75135aa2ff0311105cf343d0653bf155, usando um esquema com um sys_id de f9d083f3ff610210ef7343d3653bf12e.

var message = {
  'number': current.number.toString(),
  'short_description': current.short_description.toString(),
  'caller_id': current.caller_id.getDisplayValue(),
  'priority': current.priority.toString(),
  'state': current.state.toString()
};

var headers = {
    'origin': 'sn_business_rule'
};

var producer = new sn_ih_kafka.ProducerV2();
producer.send('75135aa2ff0311105cf343d0653bf155', gs.generateGUID(), JSON.stringify(message), false, headers, 'f9d083f3ff610210ef7343d3653bf12e');