commit 16256cbbf6cdfde8debc3254bf55ce0b8fa51b08
author Benjamin Diaz <bdiaz@whitestack.com> Thu Oct 11 12:34:20 2018 -0300
committer Benjamin Diaz <bdiaz@whitestack.com> Tue Oct 16 17:08:33 2018 -0300
tree 0895c8ae10e6717266513c5020941f90968fccee
parent a4e615d9bab28eefa0ae1e713ad75289ed2f65cc

Implements aiokafka and modifies code to support asyncio

Replaces multithreading with asyncronous calls to kafka.
Implements the async/await keywords in methods that needed
it.

Signed-off-by: Benjamin Diaz <bdiaz@whitestack.com>
Change-Id: Ic93054dc9a6b3835e2eaf1a480e5081c5eb9d4f5

setup.py

diff --git a/setup.py b/setup.py
index 86dacc4..2a85f83 100644
--- a/setup.py
+++ b/setup.py
@@ -47,7 +47,7 @@
     packages=[_name],
     include_package_data=True,
     install_requires=[
-        "kafka==1.3.*",
+        "aiokafka==0.4.*",
         "peewee==3.1.*",
         "jsonschema==2.6.*",
         "six==1.11.*",