This will be done as soon as #37 and #33 are merged. Should be few lines of code. You can see the diffs here (on top of #37). https://github.com/mahendra/kafka-python/compare/gevent...gevent-producer