ApsaraMQ for Kafka:Conecte-se ao ApsaraMQ for Kafka por meio de uma VPC

Pré-requisitos

• Você deve ter uma VPC e um vSwitch na região de destino. Caso não possua, crie-os durante a implantação.

Etapa 1: Criar uma instância

1. Faça login no console do ApsaraMQ for Kafka.

2. Na seção Quick Start, no lado direito da página, clique em Create Instance.

3. No painel exibido, selecione uma Instance Series e um billing model:

   Billing model	Use cases
   Pay-as-you-go	Ideal para desenvolvimento, testes ou cargas de trabalho com tráfego flutuante.
   Subscription	Recomendado para ambientes de produção com uso e custos previsíveis.
   Serverless	Pagamento baseado no uso real com dimensionamento elástico automático.

   Clique em OK.

4. Na página de compra, configure os parâmetros da instância:

   Parameter	Description
   Instance type	Standard (High-write) atende à maioria dos casos de uso.
   Region	Escolha a mesma região dos servidores de aplicação para minimizar a latência.
   Instance type	Selecione VPC instance.
   Traffic specification	Defina conforme o throughput estimado. Por exemplo, alikafka.hw.2xlarge suporta 20 MB/s de leitura e escrita.
   Disk type	Ultra Disk é adequado para cargas gerais. Use SSD para alto throughput ou grandes volumes de mensagens acumuladas.
   Disk capacity	Dimensione com base no período de retenção. Recomenda-se entre 300 e 900 GB.

5. Clique em Buy Now e conclua o pagamento.

Após a compra, a lista de instâncias exibirá a instância com o status Not Deployed.

Etapa 2: Obter informações da VPC

Reúna os IDs da VPC e do vSwitch necessários para a implantação.

1. Faça login no console do Virtual Private Cloud.

2. No painel de navegação à esquerda, clique em vSwitches.

3. Na barra de navegação superior, selecione a região de destino.

4. Na página vSwitches, anote as seguintes informações:

   • vSwitch ID: Localize este dado na coluna Instance ID/name.

   • VPC ID: Encontre esta informação na coluna Virtual private cloud.

Não tem uma VPC? Crie uma rapidamente

1. No console do Virtual Private Cloud, clique em Create VPC.

2. Insira um nome e defina um bloco CIDR IPv4, como 192.168.0.0/16.

3. Adicione um vSwitch durante a criação da VPC. Selecione uma zona de disponibilidade e defina um bloco CIDR de sub-rede, como 192.168.0.0/24.

Etapa 3: Implantar a instância

1. No console do ApsaraMQ for Kafka, localize a instância com status Not Deployed na página de lista de instâncias.

2. Na coluna Actions, clique em Deploy.

3. No painel Deploy Instance, configure os seguintes parâmetros:

   Parameter	Description
   VPC ID	Selecione a VPC obtida na Etapa 2.
   vSwitch ID	Selecione o vSwitch obtido na Etapa 2.
   Version	Escolha 2.6.2 (recomendado) ou 2.2.0.
   Message retention period	Tempo de retenção das mensagens. Padrão: 72 horas.
   Maximum message size	Tamanho máximo por mensagem. Padrão: 1 MB.
   Consumer offset retention period	Período de retenção dos offsets do consumidor. Padrão: 10.080 minutos (7 dias).
   Disk encryption	Ative para criptografar dados em repouso.

   Exclusivo da edição Professional:

   • Cross-zone deployment — Distribui a instância entre zonas de disponibilidade para recuperação de desastres.

   • ACL feature — Habilita o controle de acesso com autenticação SASL.

4. Clique em OK.

Etapa 4: Obter o endpoint da instância

Quando a instância estiver no estado Running:

1. Na página de lista de instâncias, clique no nome da instância para abrir os detalhes da instância.

2. Na seção Endpoint information, visualize o endpoint da instância.

   Type	Network	Protocol	Use case
   Default endpoint	VPC	PLAINTEXT	Acesso interno à VPC

   Formato de exemplo do 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 o endpoint e defina-o como valor de bootstrap.servers no seu cliente Kafka.

Etapa 5: Configurar lista de permissões de endpoint

Por padrão, apenas clientes no mesmo vSwitch podem se conectar. Para permitir acesso de outras sub-redes da VPC, configure uma lista de permissões.

1. Em Endpoint information, localize o endpoint e clique em Manage Whitelist na coluna Actions.

2. Na página Whitelist Management, clique em Add Whitelist Group.

3. Configure o grupo da lista de permissões:

   • Group name: Insira um nome, como app-servers.

   • IP addresses in group: Informe os endereços IP ou blocos CIDR permitidos.

4. Clique em OK.

Verificar conectividade de rede

Execute este comando em um servidor na sua VPC:

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

Uma conexão bem-sucedida confirma que a rede está configurada corretamente.

Próximas etapas

Com a instância implantada e em execução:

1. Criar um tópico para organizar mensagens.

2. Criar um grupo para gerenciar o consumo de mensagens.

3. Conectar sua aplicação usando o endpoint.