Kirk True created KAFKA-17397: --------------------------------- Summary: Ensure ClassicKafkaConsumer sends leave request on close even if interrupted Key: KAFKA-17397 URL: https://issues.apache.org/jira/browse/KAFKA-17397 Project: Kafka Issue Type: Bug Components: clients, consumer Affects Versions: 3.8.0, 3.9.0 Reporter: Kirk True
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{}}}. -- This message was sent by Atlassian Jira (v8.20.10#820010)