ProducerV2 - 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 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.

Esta API requer o plug-in ServiceNow IntegrationHub Action Step - Kafka Producer (com.glide.hub.action_step.kafka) e é executada no namespace sn_ih_kafka.

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

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

Tabela 1. Parâmetros

Nome	Tipo	Descrição
topicSysID	Cadeia de caracteres	Sys_id do tópico para publicar a mensagem. Os tópicos são armazenados na tabela Tópicos do Kafka [sys_kafka_topic].
chave	Cadeia de caracteres	Nome da chave para uma partição específica no tópico.
message	Cadeia de caracteres	Texto da mensagem.
isSync	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, cabeçalhos de var = { "origin": "sn_business_rule" }; chave: cadeia de caracteres. Nome do cabeçalho. valor: cadeia de caracteres. Valor do cabeçalho.

Tabela 2. Retorna

Tipo	Descrição
Nenhum

Este exemplo mostra como enviar informações de incidente alteradas para o tópico Kafka com um sys_id de 75135aa2ff0311105cf343d0653bf155.

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);