dexblog.ro
Acces rapid: Învață AI Învață Programare Specificații Dispozitive Comparații
KAFKA Toate comenzile Apache Kafka

Dead Letter Queue (DLQ) în Arhitectura Kafka în Apache Kafka

Consensul KRaft, Monitorizare și Depanare Kafka 2.0+ (Kafka Connect & Spring Kafka) Q&A / Distribuie cod

Tipar arhitectural prin care mesajele toxice sau corupte sunt redirecționate într-un topic izolat pentru analiză.

Sintaxă 
config.put("errors.deadletterqueue.topic.name", "comenzi-dlq");

Ce problemă rezolvă Dead Letter Queue

Dacă un mesaj conține un JSON invalid sau o cheie coruptă, deserializatorul consumatorului va arunca o excepție. Dacă excepția oprește procesarea, întregul grup de consumatori se blochează pe acel mesaj (Poison Pill). Tiparul Dead Letter Queue (DLQ) interceptează mesajul corupt, îl scrie într-un topic separat de carantină (ex: plati-dlq) alături de stiva de erori, permițând fluxului principal să continue fără întrerupere.

Exemplu Concret: Configurare DLQ în Kafka Connect
"errors.tolerance": "all",
"errors.deadletterqueue.topic.name": "comenzi-erori-dlq",
"errors.deadletterqueue.topic.replication.factor": "3",
"errors.deadletterqueue.context.headers.enable": "true"
Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: Dead Letter Queue (DLQ) în Arhitectura Kafka

Ai o nelămurire despre utilizarea comenzii Dead Letter Queue (DLQ) în Arhitectura Kafka sau ai descoperit un truc / fragment de cod util? Distribuie-l cu ceilalți programatori!

💬

Fii primul care pune o întrebare sau distribuie un fragment de cod / prompt!

Nu au fost adăugate încă întrebări sau exemple de cod pentru această pagină. Dacă ai întâlnit o problemă sau ai un snippet util, adaugă-l mai jos pentru a-i ajuta pe ceilalți.

Comunitate Adaugă o întrebare sau distribuie un cod

Moderare & Siguranță:

Pentru a menține calitatea și securitatea informațiilor, fiecare întrebare sau fragment de cod/prompt este analizat (manual sau prin moderare asistată de AI) înainte de publicare.