lucasbru opened a new pull request, #14226:
URL: https://github.com/apache/kafka/pull/14226
The process method inside the tasks needs to be called from within
the processing threads. However, it currently interacts with the
consumer in two ways:
- It resumes processing when the PartitionGroup buffers are empty
- It fetches the lag from the consumer
We introduce preparePoll() and wrapUpPoll() methods that call into
the task from the polling thread, in order to set up the consumer
correctly for the next poll, and extract metadata from the consumer
after the poll.
This is a stacked PR, only the last commit needs to be reviewed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
