Operasi MSK konfigurasi Amazon - Amazon Managed Streaming untuk Apache Kafka

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

Operasi MSK konfigurasi Amazon

Topik ini menjelaskan cara membuat MSK konfigurasi khusus dan cara melakukan operasi pada konfigurasi tersebut. Untuk informasi tentang cara menggunakan MSK konfigurasi untuk membuat atau memperbarui kluster, lihat. AmazonMSK: Cara kerjanya

Untuk membuat MSK konfigurasi

  1. Buat file tempat Anda menentukan properti konfigurasi yang ingin Anda atur dan nilai yang ingin Anda tetapkan padanya. Berikut ini adalah isi dari contoh file konfigurasi.

    auto.create.topics.enable = true log.roll.ms = 604800000
  2. Jalankan yang berikut AWS CLI perintah, dan ganti config-file-path dengan jalur ke file tempat Anda menyimpan konfigurasi di langkah sebelumnya.

    catatan

    Nama yang Anda pilih untuk konfigurasi Anda harus cocok dengan regex berikut: “^ [0-9A-za-Z] [0-9A-za-Z-] {0,} $”.

    aws kafka create-configuration --name "ExampleConfigurationName" --description "Example configuration description." --kafka-versions "1.1.1" --server-properties fileb://config-file-path

    Berikut ini adalah contoh respons yang berhasil setelah Anda menjalankan perintah ini.

    { "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-1234-abcd-1234-abcd123e8e8e-1", "CreationTime": "2019-05-21T19:37:40.626Z", "LatestRevision": { "CreationTime": "2019-05-21T19:37:40.626Z", "Description": "Example configuration description.", "Revision": 1 }, "Name": "ExampleConfigurationName" }
  3. Perintah sebelumnya mengembalikan Amazon Resource Name (ARN) untuk konfigurasi baru Anda. Simpan ini ARN karena Anda membutuhkannya untuk merujuk ke konfigurasi ini di perintah lain. Jika Anda kehilangan konfigurasiARN, Anda dapat membuat daftar semua konfigurasi di akun Anda untuk menemukannya lagi.

Untuk memperbarui MSK konfigurasi

  1. Buat file tempat Anda menentukan properti konfigurasi yang ingin Anda perbarui dan nilai yang ingin Anda tetapkan padanya. Berikut ini adalah isi dari contoh file konfigurasi.

    auto.create.topics.enable = true min.insync.replicas = 2
  2. Jalankan yang berikut AWS CLI perintah, dan ganti config-file-path dengan jalur ke file tempat Anda menyimpan konfigurasi di langkah sebelumnya.

    Ganti configuration-arn dengan ARN yang Anda peroleh saat Anda membuat konfigurasi. Jika Anda tidak menyimpan ARN ketika Anda membuat konfigurasi, Anda dapat menggunakan list-configurations perintah untuk mencantumkan semua konfigurasi di akun Anda. Konfigurasi yang Anda inginkan dalam daftar muncul di respons. ARNKonfigurasi juga muncul dalam daftar itu.

    aws kafka update-configuration --arn configuration-arn --description "Example configuration revision description." --server-properties fileb://config-file-path
  3. Berikut ini adalah contoh respons yang berhasil setelah Anda menjalankan perintah ini.

    { "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-1234-abcd-1234-abcd123e8e8e-1", "LatestRevision": { "CreationTime": "2020-08-27T19:37:40.626Z", "Description": "Example configuration revision description.", "Revision": 2 } }

Untuk menghapus MSK konfigurasi

Prosedur berikut menunjukkan cara menghapus konfigurasi yang tidak dilampirkan ke cluster. Anda tidak dapat menghapus konfigurasi yang dilampirkan ke klaster.

  1. Untuk menjalankan contoh ini, ganti configuration-arn dengan ARN yang Anda peroleh saat Anda membuat konfigurasi. Jika Anda tidak menyimpan ARN ketika Anda membuat konfigurasi, Anda dapat menggunakan list-configurations perintah untuk mencantumkan semua konfigurasi di akun Anda. Konfigurasi yang Anda inginkan dalam daftar muncul di respons. ARNKonfigurasi juga muncul dalam daftar itu.

    aws kafka delete-configuration --arn configuration-arn
  2. Berikut ini adalah contoh respons yang berhasil setelah Anda menjalankan perintah ini.

    { "arn": " arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-1234-abcd-1234-abcd123e8e8e-1", "state": "DELETING" }

Untuk menggambarkan MSK konfigurasi

  1. Perintah berikut mengembalikan metadata tentang konfigurasi. Untuk mendapatkan deskripsi terperinci tentang konfigurasi, jalankan filedescribe-configuration-revision.

    Untuk menjalankan contoh ini, ganti configuration-arn dengan ARN yang Anda peroleh saat Anda membuat konfigurasi. Jika Anda tidak menyimpan ARN ketika Anda membuat konfigurasi, Anda dapat menggunakan list-configurations perintah untuk mencantumkan semua konfigurasi di akun Anda. Konfigurasi yang Anda inginkan dalam daftar muncul di respons. ARNKonfigurasi juga muncul dalam daftar itu.

    aws kafka describe-configuration --arn configuration-arn
  2. Berikut ini adalah contoh respons yang berhasil setelah Anda menjalankan perintah ini.

    { "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-abcd-1234-abcd-abcd123e8e8e-1", "CreationTime": "2019-05-21T00:54:23.591Z", "Description": "Example configuration description.", "KafkaVersions": [ "1.1.1" ], "LatestRevision": { "CreationTime": "2019-05-21T00:54:23.591Z", "Description": "Example configuration description.", "Revision": 1 }, "Name": "SomeTest" }

Untuk menggambarkan MSK revisi konfigurasi

Jika Anda menggunakan describe-configuration perintah untuk mendeskripsikan MSK konfigurasi, Anda melihat metadata konfigurasi. Untuk mendapatkan deskripsi konfigurasi, gunakan perintah,describe-configuration-revision.

  • Jalankan perintah berikut dan ganti configuration-arn dengan ARN yang Anda peroleh saat Anda membuat konfigurasi. Jika Anda tidak menyimpan ARN ketika Anda membuat konfigurasi, Anda dapat menggunakan list-configurations perintah untuk mencantumkan semua konfigurasi di akun Anda. Konfigurasi yang Anda inginkan dalam daftar yang muncul dalam respons. ARNKonfigurasi juga muncul dalam daftar itu.

    aws kafka describe-configuration-revision --arn configuration-arn --revision 1

    Berikut ini adalah contoh respons yang berhasil setelah Anda menjalankan perintah ini.

    { "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-abcd-1234-abcd-abcd123e8e8e-1", "CreationTime": "2019-05-21T00:54:23.591Z", "Description": "Example configuration description.", "Revision": 1, "ServerProperties": "YXV0by5jcmVhdGUudG9waWNzLmVuYWJsZSA9IHRydWUKCgp6b29rZWVwZXIuY29ubmVjdGlvbi50aW1lb3V0Lm1zID0gMTAwMAoKCmxvZy5yb2xsLm1zID0gNjA0ODAwMDAw" }

    Nilai ServerProperties dikodekan dengan base64. Jika Anda menggunakan decoder base64 (misalnya, https://www.base64decode.org/) untuk memecahkan kode secara manual, Anda mendapatkan konten dari file konfigurasi asli yang Anda gunakan untuk membuat konfigurasi kustom. Dalam hal ini, Anda mendapatkan yang berikut:

    auto.create.topics.enable = true log.roll.ms = 604800000

Untuk mencantumkan semua MSK konfigurasi di akun Anda untuk Wilayah saat ini

  • Jalankan perintah berikut.

    aws kafka list-configurations

    Berikut ini adalah contoh respons yang berhasil setelah Anda menjalankan perintah ini.

    { "Configurations": [ { "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-abcd-1234-abcd-abcd123e8e8e-1", "CreationTime": "2019-05-21T00:54:23.591Z", "Description": "Example configuration description.", "KafkaVersions": [ "1.1.1" ], "LatestRevision": { "CreationTime": "2019-05-21T00:54:23.591Z", "Description": "Example configuration description.", "Revision": 1 }, "Name": "SomeTest" }, { "Arn": "arn:aws:kafka:us-east-1:123456789012:configuration/SomeTest/abcdabcd-1234-abcd-1234-abcd123e8e8e-1", "CreationTime": "2019-05-03T23:08:29.446Z", "Description": "Example configuration description.", "KafkaVersions": [ "1.1.1" ], "LatestRevision": { "CreationTime": "2019-05-03T23:08:29.446Z", "Description": "Example configuration description.", "Revision": 1 }, "Name": "ExampleConfigurationName" } ] }