View a markdown version of this page

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 pada cluster tanpa server.

Menyiapkan lingkungan Anda untuk membuat topik

  • Sebelum membuat topik, pastikan Anda telah mengunduh file JAR AWS MSK IAM 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 cluster MSK Serverless Anda.

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

    • Setel variabel CLASSPATH lingkungan untuk menyertakan pustaka Kafka Anda seperti yang ditunjukkan dalam 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 Anda 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