Kafka редко ломает систему в лоб. Она делает хуже: тихо гоняет одно и то же сообщение по кругу, пока consumer не начнёт **молча плодить дубли**.
Разбор кейса простой: есть сервис, есть брокер, есть обработка события. Сообщение упало на retry — и если не зафиксировать границы повторов, оно может быть обработано повторно уже после успешной попытки. Итог: повторные списания, двойные статусы, лишние уведомления, мусор в аналитике. Классика distributed-систем, а не «редкий баг» 😈
Что важно проверять в Kafka Consumer:
— idempotency обработчика
— дедупликацию по ключу события
— логику commit offset
— ограничение числа retry
— отдельный dead-letter flow, а не бесконечный круг ада
Главный вывод без магии: если consumer не умеет жить с повтором, он рано или поздно начнёт врать бизнесу. Kafka тут не виновата. Виноваты те, кто надеется, что «и так пронесёт».
—
Если копаешь сайтостроение — стоит подписаться на @SitecraftDigestPro
LinkCraft
@LinkCraftPro
Kafka редко ломает систему в лоб. Она делает хуже: тихо гоняет одно и то же сообщение по кругу, пока consumer
Этот пост опубликован в Telegram-канале LinkCraft. Подписаться можно по ссылке: @LinkCraftPro.