Produtor - com escopo (descontinuado)

A API do produtor fornece métodos que permitem enviar dados de uma instância ServiceNow para um tópico do Kafka.

Nota:

Esta API está obsoleta e foi substituída pela API ProducerV2 - Com escopo.

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

Produtor - send(cadeia de caracteres tópico, chave de cadeia de caracteres, mensagem de cadeia de caracteres, booliano isSync)

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

Tabela 1. Parâmetros

Nome	Tipo	Descrição
tópico	Cadeia de caracteres	Nome do tópico para publicar a mensagem. Um tópico armazena mensagens do mesmo tipo. Por exemplo, um tópico chamado Pagamentos pode armazenar mensagens sobre pagamentos recentes. Ao inserir o nome do tópico, inclua tudo o que vem após o prefixo do nome da instância. Por exemplo, se o nome do tópico completo for snc.<instancename> .sn_streamconnect.<topicname> , insira sn_streamconnect. no campo de tópico.
chave	Cadeia de caracteres	Nome da chave para uma partição específica. Os tópicos podem ser particionados. Mensagens com a mesma chave são armazenadas na mesma partição. Por exemplo, as mensagens de pagamento com uma chave de junho seriam todas armazenadas na mesma partição do tópico Pagamentos.
message	Cadeia de caracteres	Texto da mensagem.
isSync	Booliano	Sinalizador que indica se o fluxo deve aguardar a conclusão da etapa 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.

Tabela 2. Retorna

Tipo	Descrição
Nenhum

Este exemplo mostra como enviar informações de incidente alteradas para o tópico change_incidents do Kafka.

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 producer = new sn_ih_kafka.Producer();
producer.send('changed_incidents', current.number.toString(), JSON.stringify(message), false);