Produtor - Com escopo (descontinuado)

  • Versão de lançamento: Zurich
  • Atualizado 31 de jul. de 2025
  • 1 min. de leitura
  • . Produtor A API fornece métodos que permitem enviar dados por push de um ServiceNow Instância para um tópico do Kafka.

    Nota:
    Esta API foi descontinuada e substituída pelo ProdutorV2 - Com escopo API.

    Esta API requer ServiceNow IntegrationHub Etapa de ação - plug-in do produtor do Kafka (com.glide.hub.action_step.kafka) e é fornecido em sn_ih_kafka namespace.

    SEND (tópico de cadeia de caracteres, chave de cadeia de caracteres, mensagem de cadeia de caracteres, isSync booliano)

    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.<topicname> no campo tópico.

    chave Cadeia de caracteres Nome da chave de uma partição específica. Os tópicos podem ser particionados. As 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 de pagamentos.
    mensagem 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 aguarde a conclusão da etapa antes de continuar o fluxo associado.
    Tabela 2. Retornos
    Tipo Descrição
    Nenhum(a)

    Este exemplo mostra como enviar informações de incidente alteradas para o tópico changed_incidents 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);