Hardened the handling of already written stream events. Will now log and skip in filter processors. Previously it was able to get stuck while processing a filter that was in an inconsistent state.
Fixed
Improved error handling for filter processors, allowing the runtime to self-correct when the stream and processor state does not match
Summary
Hardened the handling of already written stream events. Will now log and skip in filter processors. Previously it was able to get stuck while processing a filter that was in an inconsistent state.
Fixed