[
https://issues.apache.org/jira/browse/KAFKA-15555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna closed KAFKA-15555.
---------------------------------
> Ensure wakeups are handled correctly in PrototypeAsyncConsumer.poll()
> ---------------------------------------------------------------------
>
> Key: KAFKA-15555
> URL: https://issues.apache.org/jira/browse/KAFKA-15555
> Project: Kafka
> Issue Type: Sub-task
> Components: clients, consumer
> Reporter: Kirk True
> Assignee: Bruno Cadonna
> Priority: Minor
> Labels: consumer-threading-refactor, kip-848-preview
> Fix For: 3.7.0
>
>
> The implementation of the {{poll()}} method in {{PrototypeAsyncConsumer}}
> does not disable wakeups in the same manner that {{KafkaConsumer}} does.
> Investigate how to make the new implementation consistent with the
> functionality of the existing implementation.
> There was a comment in the code that I plan to remove, but I will leave it
> here for reference:
> {quote}// TODO: Once we implement poll(), clear wakeupTrigger in a finally
> block: wakeupTrigger.clearActiveTask();{quote}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
