阅读背景:

如何使kafka-python或pykafka作为一个与uwsgi和gevent的异步生产者一起工作?

来源:互联网 

My Stack is uwsgi with gevents. I am trying to wrap my api end points with a decorator to push all request data (url, method, body and response) to a kafka topic, But its not working. My theory is because I am using gevents, and I am trying to run these in async mode, the async thread which actually pushes to kafka, is not able to run with gevents. And If I try to make the method sync, Then also it does not work, it dies in the produce worker, i.e. after produce the call never returns. Although both the methods work good on python shell and if I run uwsgi on threads.My Stack is uwsgi with gevents. I am trying to




你的当前访问异常,请进行认证后继续阅读剩余内容。

分享到: