Crea un argomento di Apache Kafka - Amazon Managed Streaming per Apache Kafka
Configurazione dell'ambiente per la creazione di argomentiCreazione di un argomento e scrittura di dati su di esso

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Crea un argomento di Apache Kafka

In questo passaggio, si utilizza il computer client creato in precedenza per creare un argomento sul cluster serverless.

Configurazione dell'ambiente per la creazione di argomenti

  • Prima di creare un argomento, assicuratevi di aver scaricato il file JAR AWS MSK IAM nella directory di installazione di Kafka. libs/ Se non l'hai ancora fatto, esegui il seguente comando nella directory di Kafka. libs/

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

    Questo file JAR è necessario per l'autenticazione IAM con il cluster MSK Serverless.

  • Quando si eseguono i comandi Kafka, potrebbe essere necessario assicurarsi che classpath includano il file JAR AWS MSK IAM. Per ottenere ciò, procedi in uno dei seguenti modi:

    • Imposta la variabile di CLASSPATH ambiente per includere le tue librerie Kafka, come mostrato nell'esempio seguente.

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

    • Esegui i comandi Kafka utilizzando il comando Java completo con explicitclasspath, come mostrato nell'esempio seguente.

      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

Creazione di un argomento e scrittura di dati su di esso

  1. Nel export comando seguente, sostituisci my-endpoint con la stringa bootstrap-server che hai salvato dopo aver creato il cluster. Quindi, vai alla directory kafka_2.12-2.8.1/bin sul computer client ed esegui il comando export.

    export BS=my-endpoint

  2. Esegui il comando seguente per creare un argomento chiamato 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

Fase successiva

Produci e consuma dati in MSK Serverless