Processing daemon framework using kafka as message queue, implementing consumer(s) and producer. The framework helps creating an application that will be running in a continuous manner, receiving messages, processing them and sending results (either using kafka producer or any other method).
aiokafkadaemon is available from PyPI and can be installed using pip.
pip install aiokafkadaemon
TBD