[BUG]: Kafka Sources/all type of sources are not emitting data into the stream #209

Activity

1. eneshoxha

   added this to the Cortex v3.1 milestone on Feb 6, 2026
2. eneshoxha

   self-assigned this

   on Feb 6, 2026
3. eneshoxha

   added

   bugfixThis label is in use for patch version incrementsThis label is in use for patch version increments

   on Feb 6, 2026
4. eneshoxha

   added the

   Bug

   issue type on Feb 6, 2026
5. eneshoxha commented on Feb 6, 2026

   

   eneshoxha

   on Feb 6, 2026

   ContributorAuthor

   More actions

   The critical issue was that SourceOperatorAdapter did NOT implement IErrorHandlingEnabled, which means:

   1. Error handling configuration was never propagated to source operators
   2. Exceptions thrown by downstream operators during source emit callbacks were not properly handled according to the stream's error handling strategy (Skip/Retry/Stop)
   3. This caused streams with source operators (like Kafka, Pulsar, RabbitMQ) to either hang, loop, or crash unexpectedly when errors occurred
6. eneshoxha

   linked a pull request that will close this issuev3/bug/209 : Improve error handling and diagnostics in Streams/Kafka #210on Feb 6, 2026
7. eneshoxha

   closed this as completedon Feb 10, 2026