[KAFKA-15555] Ensure wakeups are handled correctly in PrototypeAsyncConsumer.poll()

• Type: Sub-task
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 3.7.0
• Component/s: clients, consumer
• Labels: consumer-threading-refactor kip-848-preview
• Assignee: Bruno Cadonna
• Reporter: Kirk True
• Created: 05/Oct/23 21:35
• Updated: 22/Feb/24 14:50
• Resolved: 23/Nov/23 09:53

Description

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:

// TODO: Once we implement poll(), clear wakeupTrigger in a finally block: wakeupTrigger.clearActiveTask();

Issue Links

• links to: GitHub Pull Request #14746