💼 Kafka Mülakat Soruları ve Cevapları

Kafka Mülakat Soruları ve Cevapları: Kafka Hızlı Bilgi Tablosu 🎬 Mülakat Senaryosu: Consumer Lag Neden Tırmanıyor?

Kafka Hızlı Bilgi Tablosu

🎬 Mülakat Senaryosu: Consumer Lag Neden Tırmanıyor?

consumer-groups --describe

Bloklayan Senkron Çağrı

Dashboard'da consumer lag metriği tırmanıyor: 100 → 5.000 → 50.000. Bu, consumer'ın producer'dan DAHA YAVAŞ çalıştığının kanıtıdır.

Mühendis ilk adımı atar: kafka-consumer-groups.sh --describe --group order-processing-group ile o grubun her partition'daki tam durumunu sorgular.

Çıktı, LOG-END-OFFSET ile CURRENT-OFFSET arasındaki farkın (lag) her partition'da eşit büyüdüğünü gösteriyor — tek bir partition sorunu değil, tüm consumer yavaş.

Kök neden bulunur: listener metodunun içinde her mesaj için bloklayan, senkron bir dış servis çağrısı var — her mesaj işlenirken tüm partition tüketimi durur.

Düzeltme uygulanır: consumer instance sayısı, topic'in partition sayısına kadar artırılır — 6 partition için 6 consumer, paralel işleme kapasitesi 6 katına çıkar.

Final — lag metriği hızla düşer ve neredeyse sıfıra iner. Mülakat dersi: partition sayısından FAZLA consumer eklemek boşta kapasite yaratır, partition sayısına EŞİTLEMEK gerçek paralelliği açığa çıkarır.

Mülakatta Consumer Lag Sorununu Nasıl Çözersin?

Önce metriği SOMUTLAŞTIR…

Önce metriği SOMUTLAŞTIR: "lag 50.000" değil, "consumer, producer'dan 50.000 mesaj GERİDE" de — dinleyeni etkiye odaklar.

Sonra TEŞHİS adımını anlat…