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.
Gunakan lingkungan Bash di Azure Cloud Shell. Untuk informasi selengkapnya, lihat Mulai Cepat untuk Bash di Azure Cloud Shell.
Jika Anda lebih suka menjalankan perintah referensi CLI secara lokal, instal Azure CLI. Jika Anda menjalankan Windows atau macOS, pertimbangkan untuk menjalankan Azure CLI dalam kontainer Docker. Untuk informasi lebih lanjut, lihat Cara menjalankan Azure CLI di kontainer Docker.
Jika Anda menggunakan instalasi lokal, masuk ke Azure CLI dengan menggunakan perintah login az. Untuk menyelesaikan proses autentikasi, ikuti langkah-langkah yang ditampilkan di terminal Anda. Untuk opsi masuk lainnya, lihat Masuk dengan Azure CLI.
Saat Anda diminta, instal ekstensi Azure CLI pada penggunaan pertama. Untuk informasi selengkapnya tentang ekstensi, lihat Menggunakan ekstensi dengan Azure CLI.
Jalankan versi az untuk menemukan versi dan pustaka dependen yang diinstal. Untuk meningkatkan ke versi terbaru, jalankan peningkatan az.
Klon atau unduh aplikasi sampel
Klon sampel repositori:
git clone https://github.com/Azure-Samples/serviceconnector-springcloud-confluent-springboot/
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
Masuk ke Confluent Cloud menggunakan SSO yang disediakan oleh Azure
Menggunakan lingkungan default atau membuat yang baru
Buat kluster Kafka dengan informasi berikut:
- Tipe kluster: Standar
- Wilayah/zona: eastus(Virginia), Zona Tunggal
- Nama kluster:
cluster_1
atau nama lainnya.
Di Gambaran umum kluster ->Pengaturan kluster, perhatikan URL server Kafka Bootstrap.
Buat kunci API untuk kluster di Integrasi data ->Kunci API ->+ Tambahkan Kunci dengan Akses global. Catat kunci dan rahasianya.
Buat topik bernama
test
dengan partisi 6 di Topik ->+ Tambahkan topikDi bawah lingkungan default, pilih tab Schema Registry. Aktifkan Schema Registry dan catat titik akhir API.
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
Masuk ke Azure dan pilih langganan Anda.
az login az account set --subscription <Name or ID of your subscription>
Buat proyek menggunakan gradle.
./gradlew build
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.
Langkah berikutnya
Ikuti tutorial yang tercantum di bawah ini untuk mempelajari lebih lanjut tentang Konektor Layanan.