[
https://issues.apache.org/jira/browse/KAFKA-16298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822804#comment-17822804
]
Chia Chuan Yu commented on KAFKA-16298:
---------------------------------------
Hi, [~lianetm]
I'm a new contributor and I would like to take this one. Is this still
available?
Thanks!
> Ensure user callbacks exceptions are propagated to the user on consumer poll
> ----------------------------------------------------------------------------
>
> Key: KAFKA-16298
> URL: https://issues.apache.org/jira/browse/KAFKA-16298
> Project: Kafka
> Issue Type: Sub-task
> Components: clients, consumer
> Affects Versions: 3.7.0
> Reporter: Lianet Magrans
> Priority: Blocker
> Labels: callback, kip-848-client-support
> Fix For: 3.8.0
>
>
> When user-defined callbacks fail with an exception, the expectation is that
> the error should be propagated to the user as a KafkaExpception and break the
> poll loop (behaviour in the legacy coordinator). The new consumer executes
> callbacks in the application thread, and sends an event to the background
> with the callback result and error if any, [passing the error along with the
> event
> here|https://github.com/apache/kafka/blob/98a658f871fc2c533b16fb5fd567a5ceb1c340b7/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java#L1882]
> to the background thread, but does not seem to propagate the exception to
> the user.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
