Apache Kafka

Ağaçta sağ tıklayın ▸ Ekle ▸ Kafka isteği.

Ortak yapılandırma

Alan	Rolü
URL	Virgülle ayrılmış broker listesi: hote1:9092,hote2:9092 — dizenin tamamı, bölünmeden önce Handlebars ile çözümlenir
İstemci kimliği	Broker’lara bildirilen clientId
Konu	Modu ne olursa olsun, konu
Mod	produce, consume ya da browse

Kimlik doğrulama

Alan	Değerler
SASL mekanizması	none, plain, scram-sha-256, scram-sha-512
SASL kullanıcısı / SASL parolası	Parola, Gizli türünde bir değer kabul eder
TLS	Bağımsız olarak etkinleştirilebilir — SASL’siz TLS kullanan bir broker, none mekanizmasıyla çalışır

produce modu

Anahtar, değer, kayıt başlıkları ve isteğe bağlı olarak partisyon. Açıkça bir partisyon verilmezse istemci kütüphanesinin varsayılan partisyonlayıcısı geçerli olur. Yanıt, yazılan kaydın meta verilerini döndürür: konu, partisyon, offset.

consume modu

Alan	Rolü
Grup	Tüketicinin groupId değeri
Başlangıç offset’i	earliest, latest ya da specific
Belirli offset	Bir dize — Kafka offset’leri 64 bit tam sayılardır
Partisyonlar	İstemci tarafında bir filtre: partisyon atamasını yine grup yapar

browse modu

Bir partisyonu tüketici grubu olmadan inceler: Restorm sınırlı sayıda mesaj alır ve ardından bağlantıyı keser. Bu modda partisyon zorunludur.

Bir konunun içinde ne olduğuna, grup oluşturmadan ve offset kaydırmadan bakmak için doğru araç budur.

Bir senaryoda

• Kafka üretimi — tek seferlik bir eylem; kaydın meta verilerini döndürür;
• Kafka tüketimi — tüketici grubu üzerinden abone olur ve mesaj başına bir olay yayar;
• Kafka bağlantısını kapat — tüketimi durdurur.

Bkz. Bağlantılar ve akışlar.

Kod parçacıkları

Beş hedef: JavaScript (kafkajs; üretim ve tüketim için) ve kcat (üretim, tüketim, grupsuz inceleme).