Ребята, привет всем. Задача около Go-шная, но я уверен что

Question

Ребята, привет всем. Задача около Go-шная, но я уверен что

люди из чата с ней скорее всего сталкивались.

Есть сервис на Go, который обрабатывает сообщения из Kafka. И какая то часть сообщений не может быть обработана, потому что в самих сообщениях есть данные, которые текущий код обработать не может (т.е. дело не в бекинг сервисах и ретраи не помогут).

На вскидку есть решения в виде:
* падать приложению и стопать обработку, до тех пор пока код не научится с ними работать
* использовать паттерн Dead Letter Queue - пересылать все не понятное в отдельную очередь и идти дальше.

Может еще какие то варианты знаете/используете, как можно не блокировать обработку всех сообщений, но и не потерять информация о том, кто был отброшен?

#backend #go #programming #russian

0

05.02.2021

3 ответов

12 просмотров

Andrei 🦉 Sergeev

в отдельной очереди такие сообщения могут банально протухнуть, поэтому имеет смысл сохранять такие сообщения в отдельную базу с возможностью переотправки сообщения в очередь из апи / интерфейса

0

05.02.2021

Михаил Макарычев

Тут варианта 3: 1. Гонять их раунд робином 2. Просто пропускать 3. Отдельный топик Правильный выбор зависит от бизнес-логики. Не очень понятно, что вы потом будете делать с этими мёртвыми сообщениями в отдельном топике?

0

05.02.2021

Pavel Agaletskiy · Accepted Answer

Pavel Agaletskiy

Перекладывать в отдельный топик, т.е. dead letter queue. Если будете падать - система будет очень нестабильной и требующей ручного вмешательства каждый раз

0

05.02.2021

170 похожих чатов

Ребята, привет всем. Задача около Go-шная, но я уверен что

3 ответов

Похожие вопросы