Skip to content

enable mqtt, mongo, kafka as sources and sinks, parallel processing
Compare
Choose a tag to compare
@omegaml omegaml released this 03 Jul 08:36
0.2.4
e1a4809
This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
GPG key ID: 4AEE18F83AFDEB23
Expired
Learn about vigilant mode.

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

Assets 2