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

Requisitos previos

• Una instancia de ApsaraMQ for Kafka comprada, desplegada y en estado Running

Paso 1: Crear un tema de prueba

1. Inicie sesión en la consola de ApsaraMQ for Kafka.

2. En la sección Resource Distribution de la página Overview, seleccione la región donde reside su instancia.

   Importante

   Cree el tema en la misma región que la instancia de Elastic Compute Service (ECS) donde se ejecutan sus productores y consumidores. Los temas no pueden utilizarse entre regiones. Por ejemplo, si su instancia de ECS está en la región China (Beijing), cree el tema en la región China (Beijing).

3. En la página Instances, haga clic en el nombre de su instancia.

4. En el panel de navegación izquierdo, haga clic en Topics.

5. Haga clic en Create Topic.

6. En el panel Create Topic, configure los siguientes parámetros y haga clic en OK. Para una prueba rápida, utilice los valores predeterminados que se muestran a continuación. Para temas de producción, consulte las descripciones completas de los parámetros en la tabla. Una vez creado el tema, este aparecerá en la página Topics.

   Parámetro	Valor para prueba rápida	Descripción
   Name	demo	Nombre del tema.
   Description	demo test	Breve descripción del tema.
   Partitions	12	Número de particiones.
   Storage Engine	Cloud Storage	Backend de almacenamiento. Cloud Storage utiliza discos de Alibaba Cloud con tres réplicas para ofrecer baja latencia y alta confiabilidad. Local Storage emplea el algoritmo de réplicas sincronizadas (ISR) de Apache Kafka de código abierto con tres réplicas. Las instancias Standard Edition usan Cloud Storage de forma predeterminada. Solo puede seleccionar Local Storage en instancias Professional Edition. Si al crear la instancia estableció Instance Edition en Standard (High Write), únicamente estará disponible Cloud Storage.
   Message Type	Normal Message	Normal Message: Los mensajes con la misma clave se envían a la misma partición respetando el orden de envío. Si un broker falla, es posible que no se preserve el orden de los mensajes. Se configura automáticamente cuando Storage Engine es Cloud Storage. Partitionally Ordered Message: Ofrece la misma garantía de ordenamiento, pero preserva el orden incluso durante fallos del broker. Algunas particiones podrían quedar temporalmente no disponibles hasta su restauración. Se configura automáticamente cuando Storage Engine es Local Storage.
   Log Cleanup Policy	(No aplica para Cloud Storage)	Disponible solo para Local Storage en instancias Professional Edition. Delete (predeterminado): Conserva los mensajes según el periodo máximo de retención. Cuando el uso del almacenamiento supera el 85%, se eliminan los mensajes más antiguos. Compact: Conserva únicamente el valor más reciente para cada clave. Se utiliza con componentes como Kafka Connect y Confluent Schema Registry. Para más detalles, consulte compactación de registros en Apache Kafka y aliware-kafka-demos.
   Tag	demo	Etiqueta de recurso opcional.

Paso 2: Enviar un mensaje de prueba

1. En la página Topics, haga clic en el nombre del tema que creó (por ejemplo, demo).

2. En la esquina superior derecha de la página Topic Details, haga clic en Send Message.

3. En el panel Start to Send and Consume Message, seleccione un Sending Method: Console, Docker o SDK. Siga las instrucciones correspondientes al método seleccionado.

Paso 3: Comprobar el estado de la partición

Revise el estado de la partición para verificar que el mensaje llegó correctamente.

1. En la página Topics, haga clic en el nombre del tema que utilizó (por ejemplo, demo).

2. En la página Topic Details, haga clic en la pestaña Partition Status.

3. Confirme que la partición a la que envió el mensaje muestre valores actualizados en Maximum Offset y en la marca de tiempo Last Updated At. Un incremento en Maximum Offset confirma que el mensaje se almacenó correctamente.

   Parámetro	Descripción
   Partition ID	Identificador de la partición.
   Minimum Offset	Offset más antiguo en la partición.
   Maximum Offset	Offset más reciente en la partición. Si este valor aumentó después de enviar el mensaje, significa que se almacenó correctamente.
   Messages	Número total de mensajes en la partición.
   Last Updated At	Hora en que se almacenó el mensaje más reciente.

   

Paso 4: Consultar el mensaje por offset

Recupere el mensaje de prueba para confirmar que se almacenó adecuadamente.

1. Inicie sesión en la consola de ApsaraMQ for Kafka.

2. En la sección Resource Distribution de la página Overview, seleccione la región donde reside su instancia.

3. En la página Instances, haga clic en el nombre de su instancia.

4. En el panel de navegación izquierdo, haga clic en Message Query.

5. En la lista desplegable Search Method, seleccione Search by offset.

6. Seleccione el tema y la partición en las listas desplegables Topic y Partition, introduzca un valor de offset en el campo Offset y haga clic en Search. Se devolverán los mensajes cuyo offset sea mayor o igual al valor especificado. Por ejemplo, si selecciona la partición 5 e introduce el offset 5, se mostrarán todos los mensajes de la partición 5 con offset igual o superior a 5.

7. Compruebe que las columnas Key y Value coincidan con el mensaje enviado. Si la clave es demo y el valor es {"key": "test"}, significa que el broker almacenó y recuperó el mensaje correctamente.

   Parámetro	Descripción
   Partition	Partición de la que se recuperó el mensaje.
   Offset	Offset del mensaje.
   Key	Clave del mensaje, mostrada como cadena de texto.
   Value	Contenido del mensaje, mostrado como cadena de texto.
   Created At	Marca de tiempo del envío del mensaje. Corresponde a la hora registrada por el cliente o al valor del campo de marca de tiempo de ProducerRecord. Si no especificó un valor para dicho campo, se muestra la hora local del sistema al momento del envío. Si el campo de marca de tiempo se estableció en 0 o en un valor no válido, la hora se mostrará en formato 1970/x/x x:x:x. Los clientes de ApsaraMQ for Kafka versión 0.9 o anteriores no pueden configurar el campo de marca de tiempo.
   Actions	Download Key: Descarga la clave del mensaje. Download Value: Descarga el contenido del mensaje.

   Importante

   • La consola muestra hasta 1 KB de contenido por mensaje. Los mensajes más largos se truncan. Descargue el mensaje para ver el contenido completo.

   • Cada descarga tiene un límite de 10 MB. Si los resultados de la consulta superan los 10 MB, solo podrán descargarse los primeros 10 MB.

Limpieza de recursos de prueba

Una vez completada la prueba, elimine el tema de prueba para liberar espacio de almacenamiento y evitar un consumo innecesario de recursos. En la página Topics, localice el tema de prueba y haga clic en Delete.