Lianet Magrans created KAFKA-20382:
--------------------------------------
Summary: Improve interrupts handling when updating assignment for
callbacks
Key: KAFKA-20382
URL: https://issues.apache.org/jira/browse/KAFKA-20382
Project: Kafka
Issue Type: Bug
Components: clients, consumer
Reporter: Lianet Magrans
Assignee: Lianet Magrans
Fix For: 4.3.0
There is a new ApplyAssignment event triggered from the app thread to update
assignment in the background but triggered from within the poll loop.
We should add error handling around it to ensure that if it fails , it not only
propagates the exception to the poll loop, but also sends the error event to
the background, so that the ongoing reconciliation is marked completed (same
behaviour as when callbacks fails).
This ApplyAssignment is simply adding new partitions in the background, so
shouldn't fails, but waiting on it could fail if the app thread is interrupted
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
