As wme engineer i need a service that will read from project topics and create snapshots with all content.
Acceptance Criteria
- Code developed and pipeline working
TODO
- Change Snapshots GRPC API to allow new parameter named type with values article, as default, and structured
- Change the snapshots flow to listen to topics accordingly to the type
- Change the snapshots flow to marshal and unmarshall messages according to the message.key.type field. article as default, structured will do the new schema
- Get feedback from Ricardo & Prabhat on code choices (specifically passing Type through ExportRequest proto object
- Add unit tests and QA shakedown