проблема с настройкой kafka
Делаю сервис по рассылке с помощью Gmail API, pet-проект, так сказать. Сейчас основная задача: сделать так, чтобы условно 10 человек могли одновременно нажать на кнопку рассылки и у каждого рассылались свои сообщения со скоростью примерно 10 в минуту. Сначала пробовал связку celery+redis, но что-то не задалось; знающие люди (или не очень) подсказали, что для таких целей есть apache kafka. С kafka я не работал; долго маялся с запуском, поднимал через docker. Сегодня наконец-то удалось запустить рассылку, но почему-то даже при запуске на одном аккаунте сообщения дублируются в рамках одной рассылки, т.е. дважды/трижды может заслать одному и тому же человеку. По конфигурации kafka: одна тема, одна партиция, один producer, один consumer. Во-первых, хотел попросить помощи по поводу дублирования сообщений, во-вторых, узнать детали конфигурации для масштабирования и выполнения имеющейся описанной выше задачи.