Kafka + Dead Letter Topic (DLT): ловим “битые” сообщения

Когда consumer падает на отдельных сообщениях (не читается, ошибка парсинга, бизнес-логика), важно не терять данные и не блокировать поток.

💡 Решение:

• Ловим ошибку
• Отправляем сообщение в dead-letter-topic вместо крэша

Пример (Python, confluent-kafka):

try:
    process(msg.value())
except Exception:
    dlq_producer.produce("dead-letter-topic", msg.value())

📌 Зачем это нужно:

• Не теряем данные
• Разбираем ошибки отдельно
• Основной поток не блокируется

Особенно полезно в ETL, трансформациях и zip-обработке.