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)
