Skip to content

V3/main#211

Merged
eneshoxha merged 4 commits intomasterfrom
v3/main
Feb 10, 2026
Merged

V3/main#211
eneshoxha merged 4 commits intomasterfrom
v3/main

Conversation

@eneshoxha
Copy link
Contributor

No description provided.

Refactored IStream and related classes to use a single generic parameter (IStream<TIn>), removing the internal TCurrent type from the public API. Updated all builder interfaces, handlers, and usages to match the new signature. Introduced IBranchInfo for branch metadata, and updated GetBranches() to return IBranchInfo instances. This simplifies the stream abstraction and improves API encapsulation.
Refactor IStream to single generic parameter interface
- Add robust error handling to Source/SinkOperatorAdapters using ErrorHandlingHelper.TryExecute and propagate StreamExecutionOptions.
- Implement IErrorHandlingEnabled in SourceOperatorAdapter and ensure error handling is set on downstream operators.
- Add comprehensive integration and diagnostic tests for KafkaSinkOperator, including scenarios for Start(), error strategies, and custom configs.
- Introduce KafkaSinkDiagnostic console tool for troubleshooting Kafka sink usage.
- Add extensive unit tests for source operator error handling (skip, stop, retry, custom handler, no hangs/loops, FlatMap).
- Reference Cortex.Streams.Kafka in test project for integration coverage.
v3/bug/209 : Improve error handling and diagnostics in Streams/Kafka
@eneshoxha eneshoxha merged commit 2b6ea6c into master Feb 10, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant