This project was created before any of the utilities function were available, we should adapt the WDQS Streaming Updater flink to use these so that it better integrates with the event-platform.
AC:
- re-use the flink utilities function to consume/produce to kafka
- events coming out of this pipeline are validated against a well-defined schema