ApsaraMQ for Kafka:Verify an ApsaraMQ for Kafka broker with a quick test

Pré-requisitos

• Uma instância do ApsaraMQ for Kafka comprada, implantada e com o estado Running

Etapa 1: Crie um tópico de teste

1. Acesse o console do ApsaraMQ for Kafka.

2. Na seção Resource Distribution da página Overview, selecione a região onde sua instância está localizada.

   Importante

   Crie o tópico na mesma região da instância do Elastic Compute Service (ECS) onde seus produtores e consumidores estão em execução. Tópicos não podem ser usados entre regiões. Por exemplo, se sua instância ECS estiver na região China (Pequim), crie o tópico na região China (Pequim).

3. Na página Instances, clique em nome da sua instância.

4. No painel de navegação à esquerda, clique em Topics.

5. Clique em Create Topic.

6. No painel Create Topic, defina os parâmetros a seguir e clique em OK. Para um teste rápido, use os padrões mostrados abaixo. Para tópicos de produção, consulte as descrições completas dos parâmetros na tabela. Após a criação, o tópico aparece na página Topics.

   Parâmetro	Valor para teste rápido	Descrição
   Name	demo	Nome do tópico.
   Description	demo test	Breve descrição do tópico.
   Partitions	12	Quantidade de partições.
   Storage Engine	Cloud Storage	Backend de armazenamento. O Cloud Storage utiliza discos da Alibaba Cloud com três réplicas para garantir baixa latência e alta confiabilidade. Já o Local Storage emprega o algoritmo de réplicas sincronizadas (ISR) do Apache Kafka open source com três réplicas. Instâncias Standard Edition usam Cloud Storage por padrão. A opção Local Storage está disponível apenas em instâncias Professional Edition. Se você definir a Instance Edition como Standard (High Write) durante a criação da instância, somente o Cloud Storage estará disponível.
   Message Type	Normal Message	Normal Message: Mensagens com a mesma chave vão para a mesma partição na ordem de envio. Se houver falha no broker, a ordem das mensagens pode não ser preservada. Definido automaticamente quando o Storage Engine é Cloud Storage. Partitionally Ordered Message: Mesma garantia de ordenação, mas a ordem é preservada mesmo durante falhas do broker. Algumas partições podem ficar temporariamente indisponíveis até a restauração. Configurado automaticamente quando o Storage Engine é Local Storage.
   Log Cleanup Policy	(Não aplicável ao Cloud Storage)	Disponível apenas para Local Storage em instâncias Professional Edition. Delete (padrão): Retém mensagens com base no período máximo de retenção. Quando o uso do armazenamento excede 85%, as mensagens mais antigas são excluídas. Compact: Retém apenas o valor mais recente para cada chave. Usado com componentes como Kafka Connect e Confluent Schema Registry. Para obter detalhes, consulte compactação de log no Apache Kafka e aliware-kafka-demos.
   Tag	demo	Tag de recurso opcional.

Etapa 2: Enviar uma mensagem de teste

1. Na página Topics, clique em nome do tópico criado (por exemplo, demo).

2. No canto superior direito da página Topic Details, clique em Send Message.

3. No painel Start to Send and Consume Message, selecione um Sending Method: Console, Docker ou SDK. Siga as instruções correspondentes ao método escolhido.

Etapa 3: Verifique o status da partição

Verifique o status da partição para validar se a mensagem chegou.

1. Na página Topics, clique em nome do tópico utilizado (por exemplo, demo).

2. Na página Topic Details, clique em aba Partition Status.

3. Verifique se a partição de destino apresenta valores atualizados nos campos Maximum Offset e Last Updated At. Um aumento no Maximum Offset confirma que a mensagem foi armazenada com sucesso.

   Parâmetro	Descrição
   Partition ID	Identificador da partição.
   Minimum Offset	Offset mais antigo presente na partição.
   Maximum Offset	Offset mais recente na partição. Se este valor aumentou após o envio, a mensagem foi armazenada corretamente.
   Messages	Total de mensagens contidas na partição.
   Last Updated At	Horário em que a mensagem mais recente foi gravada.

   

Etapa 4: Consultar a mensagem por offset

Recupere a mensagem de teste para assegurar que ela foi armazenada adequadamente.

1. Acesse o console do ApsaraMQ for Kafka.

2. Na seção Resource Distribution da página Overview, selecione a região da sua instância.

3. Na página Instances, clique em nome da instância desejada.

4. No painel de navegação à esquerda, clique em Message Query.

5. Na lista suspensa Search Method, selecione Search by offset.

6. Escolha o tópico e a partição nas listas suspensas Topic e Partition, insira um valor de offset no campo Offset e clique em Search. Serão retornadas mensagens com offsets maiores ou iguais ao valor especificado. Por exemplo, ao selecionar a Partição 5 e inserir o Offset 5, todas as mensagens com offset igual ou superior a 5 da Partição 5 serão exibidas.

7. Valide se as colunas Key e Value correspondem à mensagem enviada. Se a chave for demo e o valor for {"key": "test"}, significa que o broker armazenou e recuperou a mensagem corretamente.

   Parâmetro	Descrição
   Partition	Partição de onde a mensagem foi recuperada.
   Offset	Offset da mensagem.
   Key	Chave da mensagem, exibida como string.
   Value	Conteúdo da mensagem, apresentado como string.
   Created At	Timestamp de envio da mensagem. Corresponde ao timestamp registrado pelo cliente ou ao valor do campo timestamp de ProducerRecord. Caso nenhum valor tenha sido especificado para o campo timestamp, a hora local do sistema no momento do envio será exibida. Se o campo timestamp tiver sido definido como 0 ou um valor inválido, a hora aparecerá no formato 1970/x/x x:x:x. Clientes em versões do ApsaraMQ for Kafka 0.9 ou anteriores não suportam a definição do campo timestamp.
   Actions	Download Key: Baixe a chave da mensagem. Download Value: Baixe o conteúdo da mensagem.

   Importante

   • O console exibe até 1 KB de conteúdo por mensagem. Mensagens maiores são truncadas. Baixe a mensagem para visualizar o conteúdo completo.

   • Cada download possui limite de 10 MB. Se os resultados da consulta ultrapassarem esse tamanho, apenas os primeiros 10 MB poderão ser baixados.

Limpar recursos de teste

Após concluir o teste com êxito, exclua o tópico de teste para liberar espaço de armazenamento e evitar consumo desnecessário de recursos. Na página Topics, localize o tópico de teste e clique em Delete.