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

Versão de lançamento: Yokohama

Atualizado 30 de jan. de 2025

2 min. de leitura

Consuma mensagens de teste de um tópico Hermes configurando dois clientes consumidores.

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 os consumidores do Hermes. Consulte Configurar uma conexão segura com o Serviço de envio de mensagens Hermes.
Baixe e instale Apache Kafka. Consulte Preparação do ambiente do cliente Apache Kafka.
Crie um tópico e produza mensagens de teste no cluster do Hermes Kafka antes de consumir mensagens. Para obter detalhes, consulte Criar um tópico de teste em Hermes usando o cliente Kafka e Produzir mensagens de teste para um tópico Hermes usando o cliente Kafka.

Função necessária: admin

Por Que e Quando Desempenhar Esta Tarefa

As etapas a seguir descrevem como configurar dois clientes consumidores e receber mensagens de teste do cluster do Kafka Hermes. Como o Hermes usa um par de clusters Kafka, é necessário configurar dois clientes consumidores com diferentes endereços de inicialização do consumidor. Isso garante que as mensagens sejam consumidas de ambos os clusters sem descartar nenhuma mensagem.

Importante:

É necessário configurar dois endereços diferentes de inicialização do consumidor, um para cada cliente consumidor.

Consulte estas etapas quando tudo estiver pronto para consumir mensagens do Hermes para fins comerciais ou de produção.

Procedimento

Navegue até o diretório de configuração de onde você extraiu o Kafka.
- Por exemplo, no Unix:
```
cd /home/user/Software/kafka/config
```
- Por exemplo, no Windows:
```
cd C:\Software\kafka\config
```
Configure os consumidores.
1. Abra o arquivo consumer.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
3. Salve as mudanças em texto sem formatação.

Consuma uma mensagem usando cada consumidor.

Execute o seguinte comando para o primeiro cliente consumidor:

Unix:

./bin/kafka-console-consumer.sh --consumer.config ./config/consumer.properties --topic snc.<instance_name>.<namespace>.sn_<app_id>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4100,<instance_name>.service-now.com:4101,<instance_name>.service-now.com:4102,<instance_name>.service-now.com:4103

Windows:

bin/windows/kafka-console-consumer.bat --consumer.config config/consumer.properties --topic snc.<instance_name>.<namespace>.sn_<app_id>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4100,<instance_name>.service-now.com:4101,<instance_name>.service-now.com:4102,<instance_name>.service-now.com:4103

Substitua as seguintes variáveis de espaço reservado:

<instance_name> com o nome da sua instância
<namespace> com o namespace do domínio ao qual seu tópico Kafka pertence (opcional)
<app_id> com o ID da aplicação
<topic_name> com um nome de tópico de teste
<consumer_group_id> com um rótulo à sua escolha para o grupo ao qual o consumidor pertence

Nota:

Cada parte do nome do tópico faz distinção entre maiúsculas e minúsculas.

Abra uma nova janela de terminal.
Navegue até o diretório do Kafka.

Execute o seguinte comando para o segundo cliente consumidor:

Unix:

./bin/kafka-console-consumer.sh --consumer.config ./config/consumer.properties --topic snc.<instance_name>.<namespace>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4200,<instance_name>.service-now.com:4201,<instance_name>.service-now.com:4202,<instance_name>.service-now.com:4203

Windows:

bin/windows/kafka-console-consumer.bat --consumer.config config/consumer.properties --topic snc.<instance_name>.<namespace>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4200,<instance_name>.service-now.com:4201,<instance_name>.service-now.com:4202,<instance_name>.service-now.com:4203

Substitua as seguintes variáveis de espaço reservado:

<instance_name> com o nome da sua instância
<namespace> com o namespace do domínio ao qual seu tópico Kafka pertence (opcional)
<topic_name> com um nome de tópico de teste
<consumer_group_id> com um rótulo à sua escolha para o grupo ao qual o consumidor pertence

Nota:

Cada parte do nome do tópico faz distinção entre maiúsculas e minúsculas.

Resultado

As mensagens de teste são consumidas a partir do cluster do Kafka no Hermes.