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.
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
Inicie sesión en la consola de ApsaraMQ for Kafka.
En la sección Quick Start, ubicada en el lado derecho de la página, haga clic en Create Instance.
-
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.
-
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.2xlargeadmite 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.
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.
Inicie sesión en la consola de Virtual Private Cloud.
En el panel de navegación izquierdo, haga clic en vSwitches.
En la barra de navegación superior, seleccione la región de destino.
-
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.
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
En la consola de Virtual Private Cloud, haga clic en Create VPC.
Introduzca un nombre y establezca un bloque CIDR IPv4, como
192.168.0.0/16.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
En la consola de ApsaraMQ for Kafka, localice la instancia en estado Not Deployed dentro de la página de instance list.
En la columna Actions, haga clic en Deploy.
-
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) o2.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.
Haga clic en OK.
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:
En la página de instance list, haga clic en el nombre de la instancia para abrir los instance details.
-
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 Copie el endpoint y configúrelo como valor de
bootstrap.serversen 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.
En Endpoint information, localice el endpoint y haga clic en Manage Whitelist dentro de la columna Actions.
En la página Whitelist Management, haga clic en Add Whitelist Group.
-
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.
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:
Create a topic para organizar los mensajes.
Create a group para gestionar el consumo de mensajes.
Connect your application mediante el endpoint.