[ https://issues.apache.org/jira/browse/STORM-2844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Hugo Louro reassigned STORM-2844: --------------------------------- Assignee: Hugo Louro > 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 > > 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 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)