Currently, we output Flink application errors to a logging sink.
We should this general purpose error schema for error side outputs and produce into a dedicated (declared per application) kafka topic. The event that caused the error should be included as a raw json string in this error events.
- Convention on error side outputs decided and documented: <job_name>.error
- Errors eventutilties stream_manager pipeline cause an error event to be emitted to an error stream.