Yes, I confirmed that in KAFKA-9331 (
https://github.com/apache/kafka/pull/9487), we removed the `catch
(exception)` block for adding uncaught exception handler.
Then, in KAFKA-12537(https://github.com/apache/kafka/pull/10387), we added
`catch (Thrwoable)` (in v2.8.0).
So, @Sinclair, if you
Not sure what version you are using, but it say `Thrwoable` in `trunk`
https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java#L577
-Matthias
On 11/18/21 6:09 AM, John Roesler wrote:
Thanks for pointing that out, Scott!
Would you mind filing a ticket for this? Would be nice to have it on the
books so other users know we know about it, and more importantly which
versions this is and is not fixed in.
Thanks for the report!
On Thu, Nov 18, 2021 at 6:10 AM John Roesler wrote:
> Thanks for pointing that out,
Thanks for pointing that out, Scott!
You’re totally right; that should be a Throwable.
Just to put it out there, do you want to just send a quick PR? If not, no
worries. I’m just asking because it seems like you’ve already done the hard
part and it might be nice to get the contribution credit.
Hi there,
I'm a big fan of KStreams - thanks for all the great work!!
I unfortunately (my fault) had a StackOverflowError bug in my KStream
transformer which meant that the KStream died without reporting any Exception
at all.
The first log message showed some polling activity and then you
