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
Loading
Please sign in to comment