Bagikan melalui


Tutorial: Menyebarkan aplikasi Spring Boot yang terhubung ke Apache Kafka di Confluent Cloud dengan Service Koneksi or di Azure Spring Apps

Pelajari cara mengakses Apache Kafka di Confluent Cloud untuk aplikasi Spring Boot yang berjalan di Azure Spring Apps. Dalam tutorial ini, Anda menyelesaikan tugas-tugas berikut:

  • Membuat Apache Kafka di Cloud Confluent
  • Membuat aplikasi Spring Cloud
  • Membangun dan menerapkan aplikasi Spring Boot
  • Koneksi Apache Kafka di Confluent Cloud ke Azure Spring Apps menggunakan Koneksi or Layanan

Prasyarat

  • Akun Azure dengan langganan aktif. Buat akun secara gratis.

  • Java 8 atau versi yang lebih baru dengan dukungan jangka panjang (LTS) 1.

Klon atau unduh aplikasi sampel

  1. Klon sampel repositori:

    git clone https://github.com/Azure-Samples/serviceconnector-springcloud-confluent-springboot/
    
  2. Navigasikan ke folder berikut:

    cd serviceconnector-springcloud-confluent-springboot
    

Menyiapkan layanan cloud

Membuat contoh Apache Kafka untuk Confluent Cloud

Buat contoh Apache Kafka untuk Confluent Cloud dengan mengikuti panduan ini.

Membuat kluster Kafka dan registri skema di Confluent Cloud

  1. Masuk ke Confluent Cloud menggunakan SSO yang disediakan oleh Azure

    The link of Confluent cloud SSO login using Azure portal

  2. Menggunakan lingkungan default atau membuat yang baru

    Cloud environment of Apache Kafka on Confluent Cloud

  3. Buat kluster Kafka dengan informasi berikut:

    • Tipe kluster: Standar
    • Wilayah/zona: eastus(Virginia), Zona Tunggal
    • Nama kluster: cluster_1 atau nama lainnya.
  4. Di Gambaran umum kluster ->Pengaturan kluster, perhatikan URL server Kafka Bootstrap.

    Cluster settings of Apache Kafka on Confluent Cloud

  5. Buat kunci API untuk kluster di Integrasi data ->Kunci API ->+ Tambahkan Kunci dengan Akses global. Catat kunci dan rahasianya.

  6. Buat topik bernama test dengan partisi 6 di Topik ->+ Tambahkan topik

  7. Di bawah lingkungan default, pilih tab Schema Registry. Aktifkan Schema Registry dan catat titik akhir API.

  8. Buat kunci API untuk registri skema. Simpan kunci dan rahasia.

Membuat instans Azure Spring Apps

Buat instans Azure Spring Apps dengan mengikuti mulai cepat Azure Spring Apps di Java. Pastikan instans Azure Spring Apps Anda dibuat di wilayah yang memiliki dukungan Service Koneksi or.

Membuat dan menyebarkan aplikasi

Membangun aplikasi sampel dan membuat aplikasi spring baru

  1. Masuk ke Azure dan pilih langganan Anda.

    az login
    
    az account set --subscription <Name or ID of your subscription>
    
  2. Buat proyek menggunakan gradle.

    ./gradlew build
    
  3. Buat aplikasi dengan titik akhir publik yang telah ditetapkan. Jika Anda memilih Java versi 11 saat membuat proyek Spring Cloud, sertakan switch --runtime-version=Java_11.

    az spring app create -n hellospring -s <service-instance-name> -g <your-resource-group-name> --assign-endpoint true
    

Membuat koneksi layanan menggunakan service Koneksi or

Jalankan perintah berikut untuk menghubungkan Apache Kafka Anda di Confluent Cloud ke aplikasi spring cloud Anda.

az spring connection create confluent-cloud -g <your-spring-cloud-resource-group> --service <your-spring-cloud-service> --app <your-spring-cloud-app> --deployment <your-spring-cloud-deployment> --bootstrap-server <kafka-bootstrap-server-url> --kafka-key <cluster-api-key> --kafka-secret <cluster-api-secret> --schema-registry <kafka-schema-registry-endpoint> --schema-key <registry-api-key> --schema-secret <registry-api-secret>

Ganti teks tempat penampung berikut dengan data Anda sendiri:

  • Ganti <your-resource-group-name> dengan nama grup sumber daya yang Anda buat untuk instans Apps Spring Apps Anda.
  • Ganti <kafka-bootstrap-server-url> dengan URL server bootstrap Kafka Anda. Sebagai contoh: pkc-xxxx.eastus.azure.confluent.cloud:9092.
  • Ganti <cluster-api-key> dan <cluster-api-secret> dengan kunci dan rahasia API kluster Anda.
  • Ganti <kafka-schema-registry-endpoint> dengan titik akhir Kafka Schema Registry Anda. Sebagai contoh: https://psrc-xxxx.westus2.azure.confluent.cloud.
  • Ganti <registry-api-key> dan <registry-api-secret> dengan kunci dan rahasia API Registri Skema kafka Anda.

Catatan

Jika Anda melihat pesan kesalahan "Langganan tidak terdaftar untuk menggunakan Microsoft.ServiceLinker", silakan jalankan az provider register -n Microsoft.ServiceLinker untuk mendaftarkan penyedia sumber daya Konektor Layanan dan jalankan perintah koneksi lagi.

Menyebarkan file JAR

Jalankan perintah berikut untuk mengunggah file JAR (build/libs/java-springboot-0.0.1-SNAPSHOT.jar) ke aplikasi Spring Cloud Anda.

az spring app deploy -n hellospring -s <service-instance-name> -g <your-resource-group-name>  --artifact-path build/libs/java-springboot-0.0.1-SNAPSHOT.jar

Memvalidasi konsumsi data Kafka

Arahkan ke titik akhir aplikasi Spring Cloud Anda dari portal Azure dan pilih URL aplikasi. Anda akan melihat "10 pesan dibuat untuk pengujian topik".

Kemudian masuk ke portal Confluent dan halaman topik akan menunjukkan throughput produksi.

Sample metrics

Langkah berikutnya

Ikuti tutorial yang tercantum di bawah ini untuk mempelajari lebih lanjut tentang Konektor Layanan.