adding source and sink support for mqtt, mongo, kafka. streaming functions are now executed asynchronously and in parallel to increase throughput
changes
e1a4809 add mongo source (18)
bc38e42 add mongo source (16)
0f7abfe kafka support (17)
41a55ac Base emitter (14)
2981d35 Example kafka ngrok (15)
fb76305 add mqtt source and skink
c1edc8f add sink support, KafkaSink
971570e test kafka source
a51e0e4 add parallel window processing using multiprocessing
61c4e56 clean up, resolved lint issues
d171487 Create actions.yml
b6ff1fa add kafka source
601776d fix missing default connection issue with mongoengine v19, mongo 4.x