Github user hmcl commented on the issue:
https://github.com/apache/storm/pull/1821
@srdo [Kafka's
InterruptException](https://kafka.apache.org/090/javadoc/org/apache/kafka/common/errors/InterruptException.html)
is a RuntimeException, otherwise the code wouldn't even compile without the
Exception either being caught or declared in the method signature. I think that
the code as is will simply throw a RuntimeException and shutdown the JVM.
We don't really do this type of check elsewhere in the codebase, and in
particular in the old spout. My opinion is that we don't need this check which
will make the code a bit more complex to little gain.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
