[jira] [Created] (STORM-2239) New Kafka spout does not properly handle interrupts

["Stig Rohde Døssing (JIRA)" <ji...@apache.org>]

Stig Rohde Døssing created STORM-2239:
-----------------------------------------

             Summary: New Kafka spout does not properly handle interrupts
                 Key: STORM-2239
                 URL: https://issues.apache.org/jira/browse/STORM-2239
             Project: Apache Storm
          Issue Type: Bug
    Affects Versions: 2.0.0, 1.0.2
            Reporter: Stig Rohde Døssing
            Assignee: Stig Rohde Døssing
            Priority: Minor


The KafkaConsumer underlying the new Kafka spout had a bug that meant that it could enter an infinite loop if certain methods were called on it from an interrupted thread. This can cause local mode clusters to hang on shutdown. It is fixed in the next Kafka release (https://issues.apache.org/jira/browse/KAFKA-4387), but a side effect is that some blocking calls on the consumer can now throw an unchecked InterruptedException variant. This will cause the executor to crash. The spout should instead catch the exception if it occurs and set thread interrupted state before returning control to Storm.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)