Panduan pengembang Apache Kafka untuk Azure Event Hubs

Artikel ini menyediakan tautan ke artikel yang menjelaskan cara mengintegrasikan aplikasi Apache Kafka Anda dengan Azure Event Hubs.

Gambaran Umum

Event Hubs menyediakan titik akhir Kafka yang dapat digunakan oleh aplikasi berbasis Kafka yang ada sebagai alternatif untuk menjalankan kluster Kafka Anda sendiri. Event Hubs berfungsi dengan banyak aplikasi Kafka Anda yang sudah ada. Untuk informasi selengkapnya, lihat Event Hubs untuk Apache Kafka

Mulai cepat

Anda dapat menemukan mulai cepat di GitHub dan dalam set konten ini yang membantu Anda dengan cepat meningkatkan Event Hubs untuk Kafka.

Mulai cepat di GitHub

Lihat mulai cepat berikut ini di repositori azure-event-hubs-for-kafka:

Bahasa/kerangka kerja klien Deskripsi
.NET

Mulai cepat ini akan menunjukkan cara membuat dan menyambungkan ke titik akhir Event Hubs Kafka menggunakan contoh produser dan konsumen yang ditulis dalam C# menggunakan .NET Core 2.0.

Sampel ini didasarkan pada klien Apache Kafka .NET Confluent, yang dimodifikasi untuk digunakan dengan Event Hubs untuk Kafka.

Java Mulai cepat ini akan menunjukkan cara membuat dan menyambungkan ke titik akhir Event Hubs Kafka menggunakan contoh produser dan konsumen yang ditulis dalam Java.
Node.js

Mulai cepat ini akan menunjukkan cara membuat dan menyambungkan ke titik akhir Event Hubs Kafka menggunakan contoh produser dan konsumen yang ditulis dalam Simpul.

Sampel ini menggunakan pustaka node-rdkafka.

Python

Mulai cepat ini akan menunjukkan cara membuat dan menyambungkan ke titik akhir Event Hubs Kafka menggunakan contoh produser dan konsumen yang ditulis dalam phyton.

Sampel ini didasarkan pada klien Apache Kafka Python Confluent, yang dimodifikasi untuk digunakan dengan Event Hubs untuk Kafka.

Go

Mulai cepat ini akan menunjukkan cara membuat dan menyambungkan ke titik akhir Event Hubs Kafka menggunakan contoh produser dan konsumen yang ditulis dalam Go.

Sampel ini didasarkan pada klien Apache Kafka Golang Confluent, yang dimodifikasi untuk digunakan dengan Event Hubs untuk Kafka.

Sarama kafka Go Mulai cepat ini akan menunjukkan cara membuat dan menyambungkan ke titik akhir Event Hubs Kafka menggunakan contoh produser dan konsumen yang ditulis dalam Go menggunakan pustaka klien Sarama Kafka.
Kafka Mulai cepat ini akan menunjukkan cara membuat dan menyambungkan ke titik akhir Event Hubs Kafka menggunakan CLI yang dilengkapi dengan distribusi Apache Kafka.
Kafkacat kafkacat adalah konsumen dan produser baris perintah non-JVM berdasarkan librdkafka, yang populer karena kecepatan dan jejaknya yang kecil. Mulai cepat ini berisi konfigurasi sampel dan beberapa sampel perintah kafkacat sederhana.

Mulai cepat di DOCS

Lihat mulai cepat: Streaming data dengan Event Hubs menggunakan protokol Kafka dalam set konten ini, yang menyediakan petunjuk langkah demi langkah tentang cara melakukan streaming ke Event Hubs. Anda mempelajari cara menggunakan produser dan konsumen untuk berkomunikasi dengan Event Hubs hanya dengan perubahan konfigurasi dalam aplikasi Anda.

Tutorial

Tutorial di GitHub

Lihat tutorial berikut di GitHub:

Tutorial Deskripsi
Akka Tutorial ini menunjukkan cara menyambungkan Akka Streams ke Event Hubs yang didukung Kafka tanpa mengubah klien protokol Anda atau menjalankan kluster Anda sendiri. Ada dua tutorial terpisah menggunakan bahasa pemrogram Java dan Scala.
Sambungkan Dokumen ini akan memandu Anda mengintegrasikan Kafka Connect dengan Azure Event Hubs dan menyebarkan konektor FileStreamSource dan FileStreamSink dasar. Meskipun tidak dimaksudkan untuk penggunaan produksi, konektor ini menunjukkan Kafka Connect Scenario menyeluruh di mana Azure Event Hubs menyamar sebagai broker Kafka.
Filebeat Dokumen ini akan memandu Anda mengintegrasikan Filebeat dan Event Hubs melalui output Kafka Filebeat.
Flink Tutorial ini menunjukkan cara menghubungkan Apache Flink ke Event Hubs yang didukung Kafka tanpa mengubah klien protokol atau menjalankan kluster Anda sendiri.
FluentD Dokumen ini akan memandu Anda mengintegrasikan Fluentd dan Event Hubs menggunakan plugin output out_kafka untuk Fluentd.
Interop Tutorial ini menunjukkan cara bertukar peristiwa antara konsumen dan produser menggunakan protokol yang berbeda.
Logstash Tutorial ini akan memandu Anda mengintegrasikan Logstash dengan Event Hubs yang didukung Kafka menggunakan plugin masukan/keluaran Logstash Kafka.
MirrorMaker Tutorial ini menunjukkan cara pusat aktivitas dan Kafka MirrorMaker mengintegrasikan alur Kafka yang ada ke Azure dengan mencerminkan aliran input Kafka di layanan Event Hubs.
NiFi Tutorial ini akan menunjukkan cara menyambungkan Apache NiFi ke namespace layanan Event Hubs.
OAuth Mulai cepat ini akan menunjukkan cara membuat dan menyambungkan ke titik akhir Event Hubs Kafka menggunakan contoh produser dan konsumen yang ditulis dalam bahasa pemrogram Go dan Java.
Registri Skema Confluent Tutorial ini akan memandu Anda mengintegrasikan Registri Skema dan Event Hubs untuk Kafka.
Spark Tutorial ini akan menunjukkan cara menyambungkan aplikasi Spark ke pusat aktivitas tanpa mengubah klien protokol atau menjalankan kluster Kafka Anda sendiri.

Tutorial dalam DOCS

Selain itu, lihat tutorial: Memproses Apache Kafka untuk peristiwa Event Hubs menggunakan analitik Stream dalam set konten ini, yang menunjukkan cara mengalirkan data ke Event Hubs dan memprosesnya dengan Azure Stream Analytics.

Panduan cara kerja

Lihat panduan Cara kerja berikut ini dalam dokumentasi kami:

Artikel Deskripsi
Mencerminkan broker Kafka di pusat aktivitas Menunjukkan cara mencerminkan broker Kafka di pusat aktivitas menggunakan Kafka MirrorMaker.
Menyambungkan Apache Spark ke pusat aktivitas Memandu Anda menyambungkan aplikasi Spark ke Event Hubs untuk streaming real time.
Menyambungkan Apache Flink ke pusat aktivitas Menunjukkan cara menyambungkan Apache Flink ke pusat aktivitas tanpa mengubah klien protokol atau menjalankan kluster Anda sendiri.
Mengintegrasikan Apache Kafka Connect dengan pusat aktivitas (Pratinjau) Memandu Anda mengintegrasikan Kafka Connect dengan pusat aktivitas dan menyebarkan konektor FileStreamSource dan FileStreamSink dasar.
Menyambungkan Akka Streams ke pusat aktivitas Menunjukkan cara menyambungkan Akka Streams ke pusat aktivitas tanpa mengubah klien protokol atau menjalankan kluster Anda sendiri.
Menggunakan Spring Boot Starter untuk Apache Kafka dengan Azure Event Hubs Menunjukkan cara mengonfigurasi Spring Cloud Stream Binder berbasis Java yang dibuat dengan Spring Boot Initializer untuk menggunakan Apache Kafka dengan Azure Event Hubs.

Langkah berikutnya

Tinjau sampel di repositori GitHub azure-event-hubs-for-kafka di bawah folder mulai cepat dan tutorial.

Lihat juga artikel berikut ini: