Kirk True created KAFKA-19651:
---------------------------------
Summary: Thread is not marked interrupted even when
AsyncKafkaConsumer.close() throws InterruptException
Key: KAFKA-19651
URL: https://issues.apache.org/jira/browse/KAFKA-19651
Project: Kafka
Issue Type: Bug
Components: clients, consumer
Affects Versions: 4.1.0
Reporter: Kirk True
Assignee: Kirk True
There is a unit tests which perform these steps:
# Create consumer
# Interrupt thread
# Call Consumer.close()
# Check that InterruptException was thrown
# Call Thread.interrupted()
In those cases, the return value from Thread.interrupted() is actually false.
We're catching the interrupted in the close() method but not restoring it
before we throw. This is inconsistent with the ClassicKafkaConsumer.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
