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
diff --git a/debian/python3-osm-policy-module.postinst b/debian/python3-osm-policy-module.postinst
index 3b24842..cd57d53 100644
--- a/debian/python3-osm-policy-module.postinst
+++ b/debian/python3-osm-policy-module.postinst
@@ -1,7 +1,7 @@
#!/bin/bash
echo "Installing python dependencies via pip..."
-pip3 install kafka==1.3.*
+pip3 install aiokafka==0.4.*
pip3 install peewee==3.1.*
pip3 install jsonschema==2.6.*
pip3 install six==1.11.*