Lianet Magrans created KAFKA-20844:
--------------------------------------
Summary: Improve inflightPoll lifecycle handling in the async
Consumer
Key: KAFKA-20844
URL: https://issues.apache.org/jira/browse/KAFKA-20844
Project: Kafka
Issue Type: Task
Components: clients, consumer
Reporter: Lianet Magrans
Assignee: Lianet Magrans
The lifecycle of the inflightPoll is managed across several methods: poll
(firstPass flag), checkInflightPoll, maybeClearPreviousInflightPoll,
maybeClearCurrentInflightPoll, and collectFetch, and the event's progress is
tracked with a mix of futures and flags, which has proven error-prone. E.g.,
KAFKA-20780 was a case not properly handled (an AsyncPollEvent that completed
on a non-first pass was not cleared, so no new fetch request was submitted).
This task is to do a high level review to make the flow easier to follow and
less error-prone. E.g., maybe explicit states or transitions around the
fetching lifecycle, also review and better separate responsibilities (actual
fetching/buffering, reconciliation, position validations, HB)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
