Topik ini menjelaskan arsitektur ApsaraMQ for Kafka dan model publikasi-langganan.
ApsaraMQ for Kafka Arsitektur
Sebuah kluster ApsaraMQ for Kafka terdiri dari produsen, broker, ZooKeeper, dan grup, seperti yang ditunjukkan dalam Arsitektur ApsaraMQ for Kafka.
Gambar 1. Arsitektur ApsaraMQ for Kafka
Produser
Seorang produser mendorong pesan ke broker ApsaraMQ for Kafka. Pesan yang dikirim dapat berupa informasi tampilan halaman, log server, serta informasi terkait sumber daya sistem seperti penggunaan CPU dan memori.
Kafka Broker
Broker adalah server yang digunakan untuk menyimpan pesan. Broker bersifat skalabel; semakin banyak broker, semakin tinggi throughput kluster ApsaraMQ for Kafka.
Grup
Grup menarik pesan dari broker ApsaraMQ for Kafka untuk berlangganan topik dan mengonsumsi pesan.
Zookeeper
Zookeeper mengelola konfigurasi kluster, memilih partisi pemimpin, serta menyeimbangkan beban ketika sebuah grup berubah.
Model Publikasi-Langganan ApsaraMQ for Kafka
ApsaraMQ for Kafka menggunakan model publikasi-langganan, seperti yang ditunjukkan dalam Model Publikasi-Langganan Message Queue for Apache Kafka.
Gambar 2. Model Publikasi-Langganan Message Queue for Apache Kafka
Grup dan topik memiliki hubungan banyak-ke-banyak. Satu grup dapat berlangganan beberapa topik, dan satu topik dapat dilanggan oleh beberapa grup.
Namun, pesan dari suatu topik yang dilanggan oleh grup hanya dapat dikonsumsi oleh satu konsumen dalam grup tersebut.