[
https://issues.apache.org/jira/browse/KAFKA-19930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18040940#comment-18040940
]
Arpit Goyal commented on KAFKA-19930:
-------------------------------------
[~mjsax] can i pick this up ?
> GlobalThread fails with NPE trying to use unsupported
> ProcessingExceptionHandler
> --------------------------------------------------------------------------------
>
> Key: KAFKA-19930
> URL: https://issues.apache.org/jira/browse/KAFKA-19930
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 3.9.0
> Reporter: Matthias J. Sax
> Priority: Minor
>
> We introduced a new `ProcessingExceptionHandler` with
> [KIP-1033|https://cwiki.apache.org/confluence/display/KAFKA/KIP-1033%3A+Add+Kafka+Streams+exception+handler+for+exceptions+occurring+during+processing]
> which was not intended to work with global Processors.
> While we might want to change this, and potentially include the GlobalThread
> (even if it would be more difficult for the follow up DLQ work, because the
> GlobalThread does not have a producer...), there is a real bug in the
> implementation: if a `Processor` on the global thread throws an exception, we
> try to use the processing exception handler, however, it was never set up,
> and we fail with a NPE trying to call
> `processingExceptionHandler.handlerError(...)` inside
> `ProcessorNode#process(...)`.
> This ticket is really just about fixing the NPE, and check if the handler is
> set, and if not, just rethrow any exception bubbling up from the user code,
> and let the global thread die (ie, let the user exception bubble up into the
> uncaught exception handler).
> We should also update the docs, calling out that this handler does not apply
> to the global thread.
> If we want to make the processing-exception-handler work properly with the
> global thread, we should file a new ticket, as it would require proper design.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
