Github user kishorvpatil commented on the issue:

    https://github.com/apache/storm/pull/2638
  
    @srdo , What I mean is there are many instances where kafka is wrapping 
actual exceptions into `InterruptedException`. I am not sure why/what is the 
objective, but only way to understand the source of origin is to log the stack 
trace here. 
    There are many kafka classes ( `KafkaConsumer`, `KafkaConsumerCoordinator` 
etc. the wrap other exceptions into `InterruptedException` . Including 
[InterruptException.java](https://github.com/apache/kafka/blob/e31c0c9bdbad432bc21b583bd3c084f05323f642/clients/src/main/java/org/apache/kafka/common/errors/InterruptException.java#L39)
 where `InterrupedException` is created



---

Reply via email to