Memigrasi ke Pusat Aktivitas Azure untuk Apache Kafka Ecosystem
Azure Event Hubs memperlihatkan titik akhir Apache Kafka, yang memungkinkan Anda untuk terhubung ke Event Hubs menggunakan protokol Kafka. Dengan melakukan sedikit perubahan pada aplikasi Kafka yang ada, Anda dapat terhubung ke Azure Event Hubs dan menikmati manfaat ekosistem Azure. Event Hubs berfungsi dengan banyak aplikasi Kafka yang sudah ada, termasuk MirrorMaker. Untuk informasi selengkapnya, lihat Event Hubs untuk Apache Kafka
Pra-migrasi
Membuat akun Azure
Jika Anda tidak memiliki langganan Azure, buat akun gratis sebelum Anda memulai.
Membuat namespace layanan Pusat Aktivitas
Untuk membuat namespace layanan Azure Event Hubs dan pusat aktivitas, Ikuti instruksi langkah demi langkah di artikel Membuat pusat aktivitas .
String koneksi
Ikuti langkah-langkah dari artikel: Dapatkan string koneksi dari portal. Selain itu, simpan string koneksi untuk digunakan nanti.
Nama domain yang sepenuhnya memenuhi syarat (FQDN)
Anda mungkin juga memerlukan FQDN yang menunjuk ke namespace Layanan Pusat Aktivitas Anda. FQDN dapat ditemukan dalam string koneksi Anda sebagai berikut:
Endpoint=sb://mynamespace.servicebus.windows.net/;SharedAccessKeyName=XXXXXX;SharedAccessKey=XXXXXX
Jika namespace Layanan Pusat Aktivitas Anda disebarkan di cloud non-publik, nama domain Anda mungkin berbeda (misalnya, *.servicebus.chinacloudapi.cn, *.servicebus.usgovcloudapi.net, atau *.servicebus.cloudapi.de).
Migration
Perbarui konfigurasi klien Kafka Anda
Untuk menyambungkan ke pusat aktivitas dengan dukungan Kafka, Anda perlu memperbarui konfigurasi klien Kafka. Jika Anda mengalami masalah saat mencarinya, coba cari di mana bootstrap.servers diatur dalam aplikasi Anda.
Masukkan konfigurasi berikut di mana pun yang memungkinkan di aplikasi Anda. Pastikan untuk memperbarui nilai bootstrap.servers dan sasl.jaas.config guna mengarahkan klien ke titik akhir Event Hubs Kafka Anda dengan autentikasi yang benar.
bootstrap.servers={MYNAMESPACE}.servicebus.windows.net:9093
request.timeout.ms=60000
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{CONNECTION STRING TO YOUR NAMESPACE}";
Jika sasl.jaas.config bukan konfigurasi yang didukung dalam kerangka kerja Anda, temukan konfigurasi yang digunakan untuk mengatur nama pengguna dan kata sandi Simple Authentication and Security Layer (SASL) dan gunakan sebagai gantinya. Atur nama pengguna $ConnectionStringdan kata sandi ke string koneksi Event Hubs Anda.
Pasca-migrasi
Jalankan aplikasi Kafka Anda yang mengirim acara ke event hub. Kemudian, verifikasi bahwa event hub menerima peristiwa menggunakan portal Azure. Pada halaman Ringkasan namespace layanan Event Hubs Anda, beralihlah ke tampilan Pesan di bagian Metrik. Refresh halaman untuk memperbarui bagan. Mungkin perlu beberapa detik agar pesan diterima.
Langkah berikutnya
Untuk mempelajari selengkapnya tentang Azure Event Hubs dan Pusat Aktivitas, lihat artikel berikut ini: