[jira] [Updated] (KAFKA-19651) Thread is not marked interrupted even when AsyncKafkaConsumer.close() throws InterruptException

["Kirk True (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-19651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Kirk True updated KAFKA-19651:
------------------------------
    Fix Version/s: 4.2.0

> 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
>            Priority: Major
>              Labels: consumer-threading-refactor
>             Fix For: 4.2.0
>
>
> 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)