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

Versão de lançamento: Washingtondc

Atualizado 1 de fev. de 2024

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.
Você deve criar um tópico e produzir mensagens de teste no cluster Kafka do Hermes 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 alguns clusters do Kafka, dois clientes consumidores são necessários. Isso significa que dois endereços de inicialização distintos devem ser usados, um para cada consumidor.

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

Procedimento

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
```
Navegue até o diretório do Kafka executando o seguinte comando:
```
cd kafka_2.13-3.1.2
```
Configure os consumidores.
1. Abra o arquivo config/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

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.

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.