[KAFKA-15867] Should ConsumerNetworkThread wrap the exception and notify the polling thread?

• Type: Task
• Status: Patch Available
• Priority: Minor
• Resolution: Unresolved
• Fix Version/s: 4.0.0
• Component/s: clients, consumer
• Labels: consumer-threading-refactor events
• Assignee: Phuc Hong Tran
• Reporter: Philip Nee
• Created: 21/Nov/23 07:46
• Updated: 29/Aug/24 17:29

Description

The ConsumerNetworkThread runs a tight loop infinitely.  However, when encountering an unexpected exception, it logs an error and continues.

 

I think this might not be ideal because user can run blind for a long time before discovering there's something wrong with the code; so I believe we should propagate the throwable back to the polling thread. 

 

cc lucasbru 

Issue Links

• links to: GitHub Pull Request #15312