Lianet Magrans created KAFKA-16298:
--------------------------------------
Summary: 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
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 coordinator executes
callbacks in the application thread, and sends en event to the background with
the callback result
([here|https://github.com/apache/kafka/blob/98a658f871fc2c533b16fb5fd567a5ceb1c340b7/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java#L252]),
but does not seem to propagate the exception to the user.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
