As a data engineer, I want to be able to use the existing Event Platform based streams declared in EventStreamConfig without having to manually write POJOs or case classes for every stream and schema.
- It will be a common need to consume existing streams so creating a utility removes the need for event service creators to do this themselves.
- 1 week?
- Simple POC service can use event schema converter for Flink Table API
- Stretch: Make is possible to use streams in DataStream API too. (This may just be converting Table API DataType Schemas to Tuple based TypeInformation schemas.)