[KAFKA-16608] AsyncKafkaConsumer doesn't honor interrupted thread status on KafkaConsumer.poll(Duration)

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 3.8.0
• Fix Version/s: 3.8.0
• Component/s: clients, consumer
• Assignee: Andrew Schofield
• Reporter: Andrew Schofield
• Created: 23/Apr/24 20:02
• Updated: 07/May/24 00:23
• Resolved: 07/May/24 00:23

Description

The behaviour for KafkaConsumer.poll(Duration) when the calling thread is in interrupted state is to throw InterruptException. The AsyncKafkaConsumer doesn't do this. It only throws that exception if the interruption occurs while it is waiting.

Issue Links

• links to: GitHub Pull Request #15803