Github user kishorvpatil commented on the issue:

    https://github.com/apache/storm/pull/2638
  
    @HeartSaVioR @srdo ., The issue in assuming that `InterruptedException` is 
only coming from external interruptions. Below is the actual example we noticed 
when Kafka Spout`TimeoutException` was wrapped in `InterruptedException`. Users 
could not identify where the exception was raised.
    
    ```
    KafkaSpoutI_[39 39] [WARN] Expecting exception of class: class 
java.lang.InterruptedException, but exception chain only contains: 
(#<TimeoutException org.apache.kafka.common.errors.TimeoutException: Failed to 
get offsets by times in 40000 ms>)```



---

Reply via email to