[
https://issues.apache.org/jira/browse/STORM-2844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hugo Louro updated STORM-2844:
------------------------------
Summary: KafkaSpout Throws IllegalStateException After Committing to Kafka
When First Poll Strategy Set to EARLIEST (was: f)
> 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 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)
