[jira] [Resolved] (STORM-2844) KafkaSpout Throws IllegalStateException After Committing to Kafka When First Poll Strategy Set to EARLIEST

["Stig Rohde Døssing (JIRA)" <ji...@apache.org>]

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

Stig Rohde Døssing resolved STORM-2844.
---------------------------------------
       Resolution: Fixed
    Fix Version/s: 1.2.0
                   2.0.0

Thanks [~hmclouro], merged both PRs.

> KafkaSpout Throws IllegalStateException After Committing to Kafka When First Poll Strategy Set to EARLIEST
> ----------------------------------------------------------------------------------------------------------
>
>                 Key: STORM-2844
>                 URL: https://issues.apache.org/jira/browse/STORM-2844
>             Project: Apache Storm
>          Issue Type: Bug
>          Components: storm-kafka-client
>    Affects Versions: 2.0.0, 1.2.0
>            Reporter: Hugo Louro
>            Assignee: Hugo Louro
>            Priority: Critical
>              Labels: pull-request-available
>             Fix For: 2.0.0, 1.2.0
>
>          Time Spent: 18h 40m
>  Remaining Estimate: 0h
>
> This [code|https://github.com/apache/storm/blob/1.x-branch/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java#L407-L409], which was committed to fix [STORM-2666|https://issues.apache.org/jira/browse/STORM-2666] throws IllegalStateException when the KafkaSpout commits to Kafka and is restarted with the same consumer group id and first poll strategy is set to EARLIEST.
> For example consider the following sequence:
> # KafkaSpout with consumer_group_id=TEST polls and commits offsets 1-5 
> # KafkaSpout with consumer_group_id=TEST is restarted with first poll strategy set to EARLIEST
> ==> IllegalStateException will be thrown
> This bug could be a blocker. I am setting it to Critical because assigning a different consumer id serves as a workaround to the problem.



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