Pull to refresh
2
Александр@Capta1n_Redbeard

User

Send message

Внешний апи может не иметь дедупликации на своей стороне, чтобы в случае сбоя мы просто как в outbox заново ему зарядили бы сообщения, которые из-за сбоя не пометили как прочитанные.

Я думаю, тут есть ещё точно достаточное кол-во вариантов, как реализовать. Просто решил осветить свой.

Тогда да, потеряем, но на то она и Кафка — сообщения можно перечитать, но это уже другая история

На случай лага сети есть те же ретраи в том числе и при отправке в Кафку, если же сам под должен будет перезапуститься, то отработает gracefull shutdown, который не даст сообщениям потеряться и завершит таски, которые уже в рантайме (либо отправиться в DLQ, либо во внешний API)

p.s. gracfull shutdown на ответственности разработчика

Information

Rating
Does not participate
Registered
Activity

Specialization

Бэкенд разработчик, Архитектор программного обеспечения
Старший
From 350,000 ₽
Python
Asyncio
Apache Kafka
Базы данных
RabbitMQ
Kubernetes
Высоконагруженные системы
gRPC
REST
Redis