Buat topik Apache Kafka - Amazon Managed Streaming untuk Apache Kafka
Menyiapkan lingkungan Anda untuk membuat topikMembuat topik dan menulis data untuk itu

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Buat topik Apache Kafka

Pada langkah ini, Anda menggunakan mesin klien yang dibuat sebelumnya untuk membuat topik di klaster tanpa server.

Menyiapkan lingkungan Anda untuk membuat topik

  • Sebelum membuat topik, pastikan Anda telah mengunduh file AWS MSK IAM JAR ke direktori instalasi Kafka Anda. libs/ Jika Anda belum melakukan ini, jalankan perintah berikut di libs/ direktori Kafka Anda.

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

    File JAR ini diperlukan untuk otentikasi IAM dengan kluster MSK Serverless Anda.

  • Saat menjalankan perintah Kafka, Anda mungkin perlu memastikan classpath menyertakan file AWS MSK IAM JAR. Untuk melakukannya, lakukan salah satu hal berikut:

    • Tetapkan variabel CLASSPATH lingkungan untuk menyertakan pustaka Kafka Anda seperti yang ditunjukkan pada contoh berikut.

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

    • Jalankan perintah Kafka menggunakan perintah Java lengkap dengan eksplisitclasspath, seperti yang ditunjukkan pada contoh berikut.

      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

Membuat topik dan menulis data untuk itu

  1. Dalam export perintah berikut, ganti my-endpoint dengan string bootstrap-server yang Anda simpan setelah Anda membuat cluster. Kemudian, pergi ke kafka_2.12-2.8.1/bin direktori pada mesin klien dan jalankan export perintah.

    export BS=my-endpoint

  2. Jalankan perintah berikut untuk membuat topik yang disebutmsk-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

Langkah Selanjutnya

Menghasilkan dan mengkonsumsi data di MSK Serverless