Releases: farbodahm/stateful-stream-processing
Releases · farbodahm/stateful-stream-processing
Add procesor application
In this release:
- Processor application is added which is the last part of the whole application.
- It asynchronously executes queries on DB and asynchronously write them on WebSocket
- Use Docker Isolated network instead of
host
mode (Issue #22) - Added Link and Docker build CI jobs
Dockerize project & Add base for front-end
In this version:
- Project is Dockerized (Both producer and consumer app)
- Also Readme is updated on how to run the applications with Docker and Docker-Compose.
- Base for Front End is placed thanks to @AlirezaEbrahimkhani
Persisting to Database
In this release:
- Data is persisted in Database
- Also database model is created with SQAlchemy
- Make logger library more readable
- Fix a bug with creating Comment model in producer
Functional Consumer
In this release:
- We have a consumer which consumes previously generated Protubuf messages
Functional Producer
In this release, we have a functional producer which:
- Generated random Twitter data
- Produces them in Kafka and set the schema on Schema Registry with Protobuf serialization
Sample Protobuf Producer-Consumer
This release will be considered as the base of the project. It contains:
- Docker compose file for setuping Kafka with Schema Registry and Zookeeper
- Sample Protobuf Producer
- Sample Protobuf Consumer