Membuat registry skema

Schema registry adalah repositori untuk mengelola skema yang digunakan oleh produsen dan konsumen Kafka Anda.

Dokumen ini menunjukkan cara membuat resource schema registry dalam Managed Service for Apache Kafka menggunakan konsolGoogle Cloud , Google Cloud CLI, atau Managed Kafka API.

Sebelum memulai

Sebelum membuat registry skema, selesaikan langkah-langkah berikut:

Peran dan izin yang diperlukan

Untuk mendapatkan izin yang diperlukan guna membuat registry skema, minta administrator untuk memberi Anda peran IAM Managed Kafka Schema Registry Editor (roles/managedkafka.schemaRegistryEditor) di project Anda. Untuk mengetahui informasi selengkapnya tentang cara memberikan peran, lihat Mengelola akses ke project, folder, dan organisasi.

Peran bawaan ini berisi izin yang diperlukan untuk membuat registry skema. Untuk melihat izin yang benar-benar diperlukan, perluas bagian Izin yang diperlukan:

Izin yang diperlukan

Izin berikut diperlukan untuk membuat registry skema:

  • Memberikan izin ini di lokasi induk: managedkafka.schemaRegistries.create

Anda mungkin juga bisa mendapatkan izin ini dengan peran khusus atau peran bawaan lainnya.

Peran tingkat lebih tinggi seperti Admin Managed Kafka Schema Registry juga memungkinkan Anda membuat dan mengelola registry skema.

Untuk mengetahui informasi selengkapnya tentang peran standar yang tersedia untuk Managed Service for Apache Kafka, lihat dokumentasi Kontrol akses.

Membuat registry skema

Konsol

  1. Di konsol Google Cloud , buka halaman Schema registries.

    Buka schema registry

    Halaman Schema registries akan terbuka.

  2. Di halaman Schema registries, klik Create.

    Halaman Create Schema registry akan terbuka.

  3. Untuk Schema registry name, masukkan ID unik untuk registry Anda.

    Nama harus diawali dengan huruf, hanya berisi huruf (a-z, A-Z), angka (0-9), dan garis bawah (_), serta terdiri dari 63 karakter atau kurang.

  4. Pilih atau masukkan Wilayah dari menu.

    Anda harus sudah memiliki satu atau beberapa cluster Managed Service for Apache Kafka yang aktif di region yang ditentukan. Untuk memeriksa region cluster Anda, lihat dokumentasi tentang mencantumkan cluster Anda.

    Untuk daftar lokasi yang didukung, lihat Lokasi Managed Service for Apache Kafka.

  5. Klik Create.

gcloud

  1. Instal Google Cloud CLI. Setelah penginstalan, inisialisasi Google Cloud CLI dengan menjalankan perintah berikut: 

    gcloud init

    Jika Anda menggunakan penyedia identitas (IdP) eksternal, Anda harus login ke gcloud CLI dengan identitas gabungan Anda terlebih dahulu.

  2. Gunakan perintah gcloud beta managed-kafka schema-registries create untuk membuat registry skema:

    gcloud beta managed-kafka schema-registries create SCHEMA_REGISTRY_ID \
    --location=LOCATION \

    Ganti kode berikut:

    • SCHEMA_REGISTRY_ID (wajib): ID unik untuk registri skema baru Anda. Bagian ini membentuk bagian dari nama resource registri. Nama harus diawali dengan huruf, hanya berisi huruf (a-z, A-Z), angka (0-9), dan garis bawah (_), serta terdiri dari 63 karakter atau kurang.
    • LOCATION (wajib): Google Cloud region tempat schema registry akan dibuat. Lokasi ini harus cocok dengan region cluster Managed Service for Apache Kafka yang menggunakan registri ini. Untuk lokasi yang didukung, lihat lokasi Managed Service for Apache Kafka.

    Untuk membuat registry skema bernama test_schema_registry di region us-central1, jalankan perintah berikut:

    gcloud beta managed-kafka schema-registries create test_schema_registry \
    --location=us-central1

    Setelah perintah berhasil diselesaikan, registry skema akan dibuat. Kemudian, Anda dapat mengonfigurasi klien Kafka untuk menggunakan URL-nya. Untuk melihat URL registri skema, lihat Detail halaman registri skema.

REST

Untuk membuat instance schema registry menggunakan REST API, lakukan langkah-langkah berikut.

  1. Kirim permintaan POST yang mirip dengan berikut ini:
    2. POST https://managedkafka.googleapis.com/v1main/projects/PROJECT_ID/locations/LOCATION/schemaRegistries
Authorization: Bearer $(gcloud auth application-default print-access-token)
Content-Type: application/json --data @response-body.json
  2. Buat file JSON request-body.json dengan struktur berikut:
    3. {
  "schemaRegistryId": "SCHEMA_REGISTRY_ID"
}

    Ganti kode berikut:

    • SCHEMA_REGISTRY_ID (wajib): ID unik untuk registri skema baru Anda. Bagian ini membentuk bagian dari nama resource registri. Nama harus diawali dengan huruf, hanya berisi huruf (a-z, A-Z), angka (0-9), dan garis bawah (_), serta terdiri dari 63 karakter atau kurang.

    Jalankan permintaan POST dengan URI, header, dan isi yang dibuat. Jika berhasil, API akan menampilkan kode status 200 OK dan isi respons yang berisi representasi JSON dari resource SchemaRegistry yang baru dibuat.

    Berikut adalah contoh respons yang berhasil.

    {
  "name": "projects/testing-311516/locations/us-central1/schemaRegistries/test",
  "contexts": [
    "projects/testing-311516/locations/us-central1/schemaRegistries/test/contexts/."
  ]
}

    projects/testing-311516/locations/us-central1/schemaRegistries/test/contexts/. mewakili konteks default. Resource dalam konteks default tidak memerlukan konteks apa pun untuk ditentukan.

    Untuk mengetahui informasi selengkapnya, lihat dokumentasi REST API.

Apache Kafka® adalah merek dagang terdaftar milik The Apache Software Foundation atau afiliasinya di Amerika Serikat dan/atau negara lain.

Langkah berikutnya