Criar um tópico de teste em Hermes usando o cliente Kafka

  • Versão de lançamento: Washingtondc
  • Atualizado 1 de fev. de 2024
  • 1 min. de leitura

    • Crie um tópico para enviar e receber mensagens de teste no cluster do Kafka da Hermes.

    Antes de Iniciar

    Proteja os tópicos do Kafka gerando um certificado assinado pela instância ServiceNow® e um repositório de chaves. Você deve fornecer detalhes do armazenamento confiável e do armazenamento de chaves ao configurar um produtor a criar um tópico no Hermes. Consulte Configurar uma conexão segura com o Serviço de envio de mensagens Hermes.

    Função necessária: admin

    Por Que e Quando Desempenhar Esta Tarefa

    Hermes Os tópicos do Kafka são nomeados usando a seguinte convenção:

    snc.<instance_name>.<namespace>.sn_<app_id>.<topic_name>
    em que:
    • <instance_name> é o nome da sua instância
    • <namespace> é o namespace do domínio ao qual seu tópico Kafka pertence (opcional)
    • <app_id> é o ID da sua aplicação

      O tópico que você cria pertence a esta aplicação. Especifique um dos seguintes:

      • sn_logstoanalytics para tópicos da Log Export Service
      • sn_streamconnect para tópicos da Stream Connect para Apache Kafka
    • <topic_name> é o nome exclusivo do seu tópico
    Nota:
    O nome completo do tópico faz distinção entre maiúsculas e minúsculas e é limitado a 200 caracteres.

    Procedimento

    1. Baixe e instale Apache Kafka.
      1. Baixar o Apache Kafka binários.
      2. Descompacte o pacote Kafka executando o seguinte comando: 
        tar -zxvf kafka_2.13-3.1.2.tgz
    2. Navegue até o diretório do Kafka executando o seguinte comando: 
      cd kafka_2.13-3.1.2
    3. Configure um produtor.
      1. Abra o arquivo config/producer.properties.
      2. Configure as seguintes propriedades de SSL: 
        security.protocol=SSL

ssl.truststore.password=<truststore password>

ssl.truststore.location=<path to truststore.p12>

ssl.truststore.type=PKCS12

ssl.keystore.password=<keystore password>

ssl.keystore.location=<path to keystore.p12>

ssl.keystore.type=PKCS12

ssl.key.password=<keystore password>
        Substitua as seguintes variáveis de espaço reservado:
        • <truststore password> com a senha do seu repositório de confiança
        • <path to truststore.p12> com o caminho para o seu arquivo do repositório de confiança
        • <keystore password> com a senha do seu repositório de chaves
        • <path to keystore.p12> com o caminho para o arquivo do seu repositório de chaves
    4. Crie um tópico de teste executando o seguinte comando:
      • Unix:
        ./bin/kafka-topics.sh --create --topic snc.<instance_name>.<namespace>.sn_<app_id>.<topic_name> --command-config ./config/producer.properties --bootstrap-server <instance_name>.service-now.com:4000,<instance_name>.service-now.com:4001,<instance_name>.service-now.com:4002,<instance_name>.service-now.com:4003
      • Windows:
        ./bin/windows/kafka-topics.bat --create --topic snc.<instance_name>.<namespace>.sn_<app_id>.<topic_name> --command-config ./config/producer.properties --bootstrap-server <instance_name>.service-now.com:4000,<instance_name>.service-now.com:4001,<instance_name>.service-now.com:4002,<instance_name>.service-now.com:4003
      Substitua as seguintes variáveis de espaço reservado:
      • <instance_name> com o nome da sua instância (diferencia maiúsculas de minúsculas)
      • <namespace> com o namespace do domínio ao qual seu tópico Kafka pertence (opcional)
      • <app_id> com o ID da aplicação (diferencia maiúsculas de minúsculas)
      • <topic_name> com o nome exclusivo do tópico que você deseja usar (diferencia maiúsculas de minúsculas)

    Resultado

    Um tópico de teste é criado no cluster Kafka da Hermes.

    O que Fazer Depois

    Produzir mensagens de teste para um tópico Hermes usando o cliente Kafka