User Story
As a platform engineer, I need to try and build a simple stateless service that takes an input stream, transforms, enriches and produces an output using PyFlink
The service should:
- Listen to mediawiki.revision-create or another existing Kafka topic
- Make a call to MW Action API
- Produce some output that combines the data
Why?
- We need to assess if this is a good abstraction for event driven data producers to create similar services easily
Done is:
- Ticket contains write up of the process (links to repos)
- Ticket contains the pros and cons of using PyFlink so that the team can make a decision on how to proceed