[KAFKA-15304] CompletableApplicationEvents aren't being completed when the consumer is closing

• Type: Sub-task
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 3.7.0
• Component/s: clients, consumer
• Labels: consumer-threading-refactor kip-848-preview
• Assignee: Philip Nee
• Reporter: Philip Nee
• Reviewer: Jun Rao
• Created: 04/Aug/23 18:26
• Updated: 24/Oct/23 21:22
• Resolved: 24/Oct/23 21:22

Description

If the background thread is closed before ingesting all ApplicationEvents, we should drain the background queue and try to cancel these events before closing. We can try to process these events before closing down the consumer; however, we assume that when the user issues a close command, the consumer should be shut down promptly.

Issue Links

• is related to: KAFKA-14274 Introduce FetchRequestManager to integrate fetch into new consumer threading refactor