Как реализовать разделение задач между воркерами с учетом падения воркера и ребалансировки задач? (Python)

Как устроена схема консюмер-продюсер в Kafka?

Как использовать Kafka для распределения большого количества задач между воркерами?

Как реализовать взаимодействие между балансировщиком и инстансами для распределения нагрузки и обработки ошибок?

Когда и где закрывать сессию SQLAlchemy

Как устроена схема консюмер-продюсер в Kafka?

Как использовать Kafka для распределения большого количества задач между воркерами?

Как реализовать взаимодействие между балансировщиком и инстансами для распределения нагрузки и обработки ошибок?

Когда и где закрывать сессию SQLAlchemy