Bagikan melalui


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

Azure Event Hubs menyediakan titik akhir Kafka yang dapat digunakan aplikasi berbasis Kafka Yang ada sebagai alternatif untuk menjalankan kluster Kafka Anda sendiri. Azure 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 menunjukkan cara membuat dan menyambungkan ke titik akhir Event Hubs Kafka menggunakan contoh produsen 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 menunjukkan cara membuat dan menyambungkan ke titik akhir Event Hubs Kafka menggunakan contoh produsen dan konsumen yang ditulis dalam Java.
Node.js

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

Sampel ini menggunakan pustaka node-rdkafka.

Python

Mulai cepat ini menunjukkan cara membuat dan menyambungkan ke titik akhir Azure Event Hubs Kafka menggunakan contoh produsen dan konsumen yang ditulis dalam python.

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

Go

Mulai cepat ini menunjukkan cara membuat dan menyambungkan ke titik akhir Event Hubs Kafka menggunakan contoh produsen 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 menunjukkan cara membuat dan menyambungkan ke titik akhir Event Hubs Kafka menggunakan contoh produsen dan konsumen yang ditulis di Go menggunakan pustaka klien Sarama Kafka.
Kafka Mulai cepat ini menunjukkan cara membuat dan menyambungkan ke titik akhir Azure Event Hubs Kafka menggunakan CLI yang dibundel dengan distribusi Apache Kafka.
kcat kcat adalah konsumen dan produsen baris perintah non-JVM berdasarkan librdkafka, 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 produsen dan konsumen Anda untuk berbicara dengan Azure 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 memancing Anda mengintegrasikan Kafka Connect dengan Azure Event Hubs dan menyebarkan konektor FileStreamSource dan FileStreamSink dasar. Meskipun konektor ini tidak dimaksudkan untuk penggunaan produksi, konektor ini menunjukkan Skenario Kafka Connect end-to-end di mana Azure Event Hubs menyatu sebagai broker Kafka.
Filebeat Dokumen ini memancang Anda mengintegrasikan Filebeat dan Event Hubs melalui output Kafka Filebeat.
Flink Tutorial ini menunjukkan cara menghubungkan Apache Flink ke Event Hubs yang diaktifkan Kafka tanpa mengubah klien protokol Anda atau menjalankan kluster Anda sendiri.
FluentD Dokumen ini memancang Anda mengintegrasikan Fluentd dan Event Hubs menggunakan out_kafka plugin output untuk Fluentd.
Interop Tutorial ini menunjukkan cara bertukar peristiwa antara konsumen dan produser menggunakan protokol yang berbeda.
Logstash Tutorial ini memandikan Anda mengintegrasikan Logstash dengan Event Hubs yang mendukung Kafka menggunakan plugin input/output 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 menunjukkan cara menyambungkan Apache NiFi ke namespace Layanan Pusat Aktivitas.
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 memandikan Anda mengintegrasikan Schema Registry dan Event Hubs untuk Kafka.
Spark Tutorial ini menunjukkan cara menghubungkan aplikasi Spark Anda ke pusat aktivitas tanpa mengubah klien protokol Anda 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 perantara 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: