[KAFKA-17397] Ensure ClassicKafkaConsumer sends leave request on close even if interrupted

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 3.8.0, 3.9.0
• Component/s: clients, consumer
• Labels: integration-tests
• Assignee: Unassigned
• Reporter: Kirk True
• Created: 21/Aug/24 23:57
• Updated: 12/Oct/24 05:58

Description

During testing for KAFKA-16985, a new, parameterized integration test was added to PlaintextConsumerTest named testCloseLeavesGroupOnInterrupt(). When the test is executed locally, it passes using both the AsyncKafkaConsumer and the ClassicKafkaConsumer. However, when the test is run in the Apache CI environment, it passes for the AsyncKafkaConsumer but fails for the ClassicKafkaConsumer. Rather than hold up KAFKA-16985, this Jira was filed to investigate and fix the ClassicKafkaConsumer.