Criar um tópico do Apache Kafka - Amazon Managed Streaming for Apache Kafka
Configurando seu ambiente para criar tópicosCriando um tópico e gravando dados nele

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Criar um tópico do Apache Kafka

Nesta etapa, você usa a máquina cliente criada anteriormente para criar um tópico no cluster com tecnologia sem servidor.

Configurando seu ambiente para criar tópicos

  • Antes de criar um tópico, certifique-se de ter baixado o arquivo JAR do AWS MSK IAM para o diretório de instalação do Kafka. libs/ Se você ainda não fez isso, execute o seguinte comando no diretório do libs/ Kafka.

    wget https://github.com/aws/aws-msk-iam-auth/releases/download/v2.3.0/aws-msk-iam-auth-2.3.0-all.jar

    Esse arquivo JAR é necessário para a autenticação do IAM com seu cluster MSK Serverless.

  • Ao executar comandos do Kafka, talvez seja necessário garantir que eles classpath incluam o arquivo JAR do AWS MSK IAM. Para isso, execute um dos seguintes procedimentos:

    • Defina a variável de CLASSPATH ambiente para incluir suas bibliotecas do Kafka, conforme mostrado no exemplo a seguir.

      export CLASSPATH=<path-to-your-kafka-installation>/libs/*:<path-to-your-kafka-installation>/libs/aws-msk-iam-auth-2.3.0-all.jar

    • Execute os comandos do Kafka usando o comando Java completo com explícitoclasspath, conforme mostrado no exemplo a seguir.

      java -cp "<path-to-your-kafka-installation>/libs/*:<path-to-your-kafka-installation>/libs/aws-msk-iam-auth-2.3.0-all.jar" org.apache.kafka.tools.TopicCommand --bootstrap-server $BS --command-config client.properties --create --topic msk-serverless-tutorial --partitions 6

Criando um tópico e gravando dados nele

  1. No export comando a seguir, my-endpoint substitua pela string bootstrap-server que você salvou depois de criar o cluster. Em seguida, acesse o diretório kafka_2.12-2.8.1/bin na máquina cliente e execute o comando export.

    export BS=my-endpoint

  2. Execute o comando a seguir para criar um tópico chamado msk-serverless-tutorial.

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --bootstrap-server $BS --command-config client.properties --create --topic msk-serverless-tutorial --partitions 6

Próxima etapa

Produzir e consumir dados no MSK Sem Servidor