[ https://issues.apache.org/jira/browse/KAFKA-796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Manikumar resolved KAFKA-796. ----------------------------- Resolution: Auto Closed Closing inactive issue. The scala clients are no longer supported. > Kafka Scala classes should declare thrown checked exceptions to be Java > friendly > -------------------------------------------------------------------------------- > > Key: KAFKA-796 > URL: https://issues.apache.org/jira/browse/KAFKA-796 > Project: Kafka > Issue Type: Bug > Components: core > Reporter: Darren Sargent > Priority: Minor > > For example, ConsumerIterator makeNext() method calls BlockingQueue.take() > which declares it throws InterruptedException. However, since makeNext() > fails to redeclare this exception, Java client code will be unable to catch > it -- javac will complain that InterruptedException cannot be thrown. > Workaround - in the Java client code, catch Exception then check if > instanceof InterruptedException and respond accordingly. But really the Scala > method should redeclare checked exceptions for Java's benefit, even though > it's not required for Scala since there are no checked exceptions. > There may be other classes where this needs to be done as well. -- This message was sent by Atlassian JIRA (v7.6.3#76005)