Etapa 3: criar a máquina cliente e o tópico do Apache Kafka

Nesta etapa, você vai criar uma instância do Amazon EC2 para usar como uma instância do cliente do Apache Kafka. Em seguida, você usará essa instância para criar um tópico no cluster.

Como criar uma máquina cliente

1. Abra o console do Amazon EC2 em https://console.aws.amazon.com/ec2/.

2. Selecione Iniciar instâncias.

3. Insira um Nome para sua máquina cliente, como mkc-tutorial-client.

4. Deixe a opção AMI do Amazon Linux 2 (HVM) – Kernel 5.10, tipo de volume SSD selecionada para Tipo de imagem de máquina da Amazon (AMI).

5. Escolha o tipo de instância t2.xlarge.

6. Na seção Par de chaves, escolha Criar um novo par de chaves. Digite mkc-tutorial-key-pair em Nome do par de chaves e, em seguida, escolha Baixar par de chaves. Se preferir, use um par de chaves existente.

7. Escolha Iniciar instância.

8. Escolha View Instances (Exibir instâncias). Na coluna Grupos de segurança, escolha o grupo de segurança que está associado à sua nova instância. Copie o ID do grupo de segurança e salve-o para usar posteriormente.

Para permitir que o cliente recém-criado envie dados para o cluster

1. Abra o console do Amazon VPC em https://console.aws.amazon.com/vpc/.

2. No painel esquerdo, em SEGURANÇA, escolha Grupos de segurança). Na coluna ID do grupo de segurança, localize o grupo de segurança do cluster. Você salvou o ID desse grupo de segurança ao criar o cluster em Etapa 1: configurar os recursos necessários. Escolha esse grupo de segurança marcando a caixa à esquerda de sua linha. Certifique-se de que nenhum outro grupo de segurança seja selecionado simultaneamente.

3. Na metade inferior da tela, escolha a guia Regras de entrada.

4. Escolha Editar regras de entrada.

5. Na parte inferior esquerda da tela, escolha Adicionar regra.

6. Na nova regra, escolha All traffic (Todo o tráfego) na coluna Type (Tipo). No campo à direita da coluna Origem, insira o ID do grupo de segurança da máquina cliente. Trata-se do ID do grupo de segurança que você salvou após criar a máquina cliente.

7. Escolha Salvar regras. Agora, seu cluster do MSK aceitará todo o tráfego do cliente criado no procedimento anterior.

Para criar um tópico

1. Abra o console do Amazon EC2 em https://console.aws.amazon.com/ec2/.

2. Na tabela de instâncias, escolha mkc-tutorial-client.

3. Na parte superior da tela, escolha Connect e siga as instruções para se conectar à instância.

4. Instale o Java na instância do cliente executando o seguinte comando:

   sudo yum install java-1.8.0

5. Execute o comando a seguir para fazer download do Apache Kafka.

   wget https://archive.apache.org/dist/kafka/2.2.1/kafka_2.12-2.2.1.tgz

   nota

   Se quiser usar um local de espelhamento diferente do usado neste comando, você poderá escolher um local diferente no site do Apache.

6. Execute o comando a seguir no diretório onde você fez download do arquivo TAR na etapa anterior.

   tar -xzf kafka_2.12-2.2.1.tgz

7. Acesse o diretório kafka_2.12-2.2.1.

8. Abra o console do Amazon MSK em https://console.aws.amazon.com/msk/home?region=us-east-1#/home/.

9. No painel esquerdo, escolha Clusters e, em seguida, escolha o nome mkc-tutorial-cluster.

10. Escolha Exibir informações do cliente.

11. Copie a string de conexão em texto simples.

12. Selecione Done (Concluído).

13. Execute o comando a seguir na instância do cliente (mkc-tutorial-client), bootstrapServerStringsubstituindo-o pelo valor que você salvou ao visualizar as informações do cliente do cluster.

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --create --bootstrap-server bootstrapServerString --replication-factor 2 --partitions 1 --topic mkc-tutorial-topic

    Se o comando tiver êxito, a seguinte mensagem será exibida: Created topic mkc-tutorial-topic.

Próxima etapa

Etapa 4: criar conector