Todos los productos
Search
Centro de documentos

ApsaraMQ for Kafka:Conexión a ApsaraMQ for Kafka mediante una VPC

Última actualización: Sep 04, 2026

Cree y despliegue una instancia de ApsaraMQ for Kafka, y obtenga el endpoint de VPC para conectar su cliente de Kafka.

Requisitos previos

  • Debe existir una VPC y un vSwitch en la región de destino. Si es necesario, puede crearlos durante el despliegue.

Nota

En el primer despliegue, la consola le solicitará que autorice el rol vinculado al servicio AliyunServiceRoleForAlikafka. Haga clic en OK para otorgar los permisos obligatorios.

Paso 1: Crear una instancia

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

  2. En la sección Quick Start, ubicada en el lado derecho de la página, haga clic en Create Instance.

  3. En el panel que aparece, seleccione una Instance Series y un billing model:

    Billing model

    Casos de uso

    Pay-as-you-go

    Ideal para desarrollo, pruebas o cargas de trabajo con tráfico fluctuante.

    Subscription

    Recomendado para entornos de producción con uso y costos predecibles.

    Serverless

    Pago basado en el uso real con escalado elástico automático.

    Haga clic en OK.

  4. En la página de compra, configure los parámetros de la instancia:

    Parámetro

    Descripción

    Instance type

    Standard (High-write) es adecuada para la mayoría de los casos de uso.

    Region

    Seleccione la misma región donde se encuentran sus servidores de aplicaciones para minimizar la latencia.

    Instance type

    Elija VPC instance.

    Traffic specification

    Seleccione según el throughput estimado. Por ejemplo, alikafka.hw.2xlarge admite 20 MB/s de lectura y escritura.

    Disk type

    Ultra Disk es apropiado para cargas de trabajo generales. Utilice SSD si requiere alto throughput o tiene grandes acumulaciones de mensajes.

    Disk capacity

    Determine la capacidad según el periodo de retención. Se recomienda entre 300 y 900 GB.

  5. Haga clic en Buy Now y complete el pago.

Después de la compra, la instance list mostrará la instancia en estado Not Deployed.

Paso 2: Obtener información de la VPC

Recopile los identificadores de VPC y vSwitch necesarios para el despliegue.

  1. Inicie sesión en la consola de Virtual Private Cloud.

  2. En el panel de navegación izquierdo, haga clic en vSwitches.

  3. En la barra de navegación superior, seleccione la región de destino.

  4. En la página vSwitches, registre la siguiente información:

    • vSwitch ID: Localícelo en la columna Instance ID/name.

    • VPC ID: Encuéntrelo en la columna Virtual private cloud.

Nota

El vSwitch determina la zona de disponibilidad de la instancia. Elija uno cercano a sus servidores de aplicaciones para reducir la latencia.

¿No tiene una VPC? Cree una rápidamente

  1. En la consola de Virtual Private Cloud, haga clic en Create VPC.

  2. Introduzca un nombre y establezca un bloque CIDR IPv4, como 192.168.0.0/16.

  3. Agregue un vSwitch durante la creación de la VPC. Seleccione una zona de disponibilidad y defina un bloque CIDR de subred, por ejemplo 192.168.0.0/24.

Paso 3: Desplegar la instancia

  1. En la consola de ApsaraMQ for Kafka, localice la instancia en estado Not Deployed dentro de la página de instance list.

  2. En la columna Actions, haga clic en Deploy.

  3. En el panel Deploy Instance, configure los siguientes parámetros:

    Parámetro

    Descripción

    VPC ID

    Seleccione la VPC obtenida en el paso 2.

    vSwitch ID

    Seleccione el vSwitch obtenido en el paso 2.

    Version

    Elija 2.6.2 (recomendado) o 2.2.0.

    Message retention period

    Tiempo de conservación de los mensajes. Valor predeterminado: 72 horas.

    Maximum message size

    Tamaño máximo permitido por mensaje. Valor predeterminado: 1 MB.

    Consumer offset retention period

    Tiempo de retención de los offsets del consumidor. Valor predeterminado: 10,080 minutos (7 días).

    Disk encryption

    Habilite esta opción para cifrar los datos en reposo.

    Exclusivo de la edición Professional:

    • Cross-zone deployment — Distribuya la instancia entre varias zonas de disponibilidad para garantizar la recuperación ante desastres.

    • ACL feature — Habilite el control de acceso con autenticación SASL.

  4. Haga clic en OK.

Nota

El despliegue tarda entre 10 y 30 minutos. El estado de la instancia cambiará de Deploying a Running.

Paso 4: Obtener el endpoint de la instancia

Una vez que la instancia esté en estado Running:

  1. En la página de instance list, haga clic en el nombre de la instancia para abrir los instance details.

  2. En la sección Endpoint information, consulte el endpoint de la instancia.

    Tipo

    Red

    Protocolo

    Caso de uso

    Endpoint predeterminado

    VPC

    PLAINTEXT

    Acceso desde dentro de la VPC

    Formato de ejemplo del endpoint:

    alikafka-pre-public-intl-sg-xxxxx-1-vpc.alikafka.aliyuncs.com:9092,
    alikafka-pre-public-intl-sg-xxxxx-2-vpc.alikafka.aliyuncs.com:9092,
    alikafka-pre-public-intl-sg-xxxxx-3-vpc.alikafka.aliyuncs.com:9092
  3. Copie el endpoint y configúrelo como valor de bootstrap.servers en su cliente de Kafka.

Paso 5: Configurar la lista de permitidos del endpoint

De forma predeterminada, solo pueden conectarse los clientes que se encuentran en el mismo vSwitch. Para permitir el acceso desde otras subredes de la VPC, configure una lista de permitidos.

  1. En Endpoint information, localice el endpoint y haga clic en Manage Whitelist dentro de la columna Actions.

  2. En la página Whitelist Management, haga clic en Add Whitelist Group.

  3. Configure el grupo de la lista de permitidos:

    • Group name: Introduzca un nombre, por ejemplo app-servers.

    • IP addresses in group: Especifique las direcciones IP o bloques CIDR que desea permitir.

  4. Haga clic en OK.

Comprobación de la conectividad de red

Ejecute este comando desde un servidor dentro de su VPC:

telnet alikafka-pre-public-intl-sg-xxxxx-1-vpc.alikafka.aliyuncs.com 9092

Si la conexión se establece correctamente, significa que la red está configurada de manera adecuada.

Siguientes pasos

Con la instancia desplegada y en ejecución:

  1. Create a topic para organizar los mensajes.

  2. Create a group para gestionar el consumo de mensajes.

  3. Connect your application mediante el endpoint.