Тайм-аут производителя python-kafka в приложении uwsgi python

У меня проблема со связью с моим сервером kafka, когда мое приложение flask работает с uwsgi/nginx. Когда я запускаю приложение с помощью python в командной строке, все проходит нормально. Но когда я запускаю его с императором uwsgi, мой продюсер выжидает ответа. Создание производителя работает как положено; У меня проблема только с попыткой отправить новое сообщение. Я проверил, что сообщение никогда не доходит до сервера, но исключение, вызванное ожиданием ответа, просто «Тайм-аут после ожидания в течение 5 секунд».

Как устранить эту проблему? В приложении все работает нормально, просто не могу отправлять сообщения kafka. Нужны ли какие-либо специальные настройки, чтобы приложение могло обмениваться данными через другие сокеты?

Что я пробовал:

  • Настройка close-on-exec в моей конфигурации ini
  • отключение многопоточности
  • ограничиться одним процессом

person Matt Viss    schedule 05.08.2016    source источник


Ответы (1)


вы можете взглянуть на статью ниже, возможно, она решит вашу проблему. https://github.com/dpkp/kafka-python/issues/721

введите здесь описание изображения

person bruceguodong    schedule 27.03.2017