[jira] [Updated] (STORM-2184) New Kafka spout will fail to commit offsets on shutdown if there are offsets to commit

["Hugo Louro (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/STORM-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Hugo Louro updated STORM-2184:
------------------------------
    Component/s: storm-kafka-client

> New Kafka spout will fail to commit offsets on shutdown if there are offsets to commit
> --------------------------------------------------------------------------------------
>
>                 Key: STORM-2184
>                 URL: https://issues.apache.org/jira/browse/STORM-2184
>             Project: Apache Storm
>          Issue Type: Bug
>          Components: storm-kafka-client
>            Reporter: Stig Rohde Døssing
>            Assignee: Stig Rohde Døssing
>            Priority: Trivial
>             Fix For: 2.0.0, 1.1.0, 1.0.3
>
>          Time Spent: 40m
>  Remaining Estimate: 0h
>
> As far as I know spout methods are not called concurrently by Storm. When the new Kafka spout closes or deactivates, the closing thread calls KafkaConsumer.wakeup. If there are uncommitted offsets and the spout is in manual commit mode, it then tries to commit offsets. Since there are no other threads concurrently interacting with the spout, the call to KafkaConsumer.commitSync will end up throwing WakeupException. This is because the behavior of wakeup is to cause the next blocking call to throw WakeupException if there are no other threads blocking on the consumer when wakeup is called. 
> The call to wakeup should be removed, since it does nothing if there are no offsets to commit, and causes an uncaught exception if there are.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)