[
https://issues.apache.org/jira/browse/STORM-2844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16302599#comment-16302599
]
Hugo Louro commented on STORM-2844:
-----------------------------------
[~erikdw] The 1.2.0 and 1.1.x branches have diverged quite a bit and it is
difficult to backport every change. I think it that it is reasonable to expect
that some fixes will be included only in minor versions, and therefore require
a minor upgrade. I don't think it is in the plan to backport this change.
> 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
> Time Spent: 17h 10m
> 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)
