Information
- Rating
- Does not participate
- Registered
- Activity
Specialization
Бэкенд разработчик, Архитектор программного обеспечения
Старший
From 350,000 ₽
Python
Asyncio
Apache Kafka
Базы данных
RabbitMQ
Kubernetes
Высоконагруженные системы
gRPC
REST
Redis
Внешний апи может не иметь дедупликации на своей стороне, чтобы в случае сбоя мы просто как в outbox заново ему зарядили бы сообщения, которые из-за сбоя не пометили как прочитанные.
Я думаю, тут есть ещё точно достаточное кол-во вариантов, как реализовать. Просто решил осветить свой.
Тогда да, потеряем, но на то она и Кафка — сообщения можно перечитать, но это уже другая история
На случай лага сети есть те же ретраи в том числе и при отправке в Кафку, если же сам под должен будет перезапуститься, то отработает gracefull shutdown, который не даст сообщениям потеряться и завершит таски, которые уже в рантайме (либо отправиться в DLQ, либо во внешний API)
p.s. gracfull shutdown на ответственности разработчика