User Story
As a platform engineer, I need proper error handling in a stateless streaming processor so that errors are understood and corrected
Simple stateless services should have the same level of reliability of Scala ones.
Http callbacks should implement a retry logic, malformed records and errors should be logged, metrics should be collected in prometheus.
Need grooming
We should investigate how support for sideoutput can be automatically provided to SQL and pyflink
pipelines.