[Feature]: Error Handling and Resilience #154
Description
Currently, if a user function in MapOperator, FilterOperator or SinkOperator and other Operators throws an exception, the exception propagates and the stream stops. Provide optional error handlers that receive the exception and the offending element, allowing the pipeline to either skip the element, retry, or stop gracefully. Adding OnError callbacks makes the system more resilient.