You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@storm.apache.org by "Hugo Louro (JIRA)" <ji...@apache.org> on 2017/12/06 19:25:00 UTC
[jira] [Updated] (STORM-2844) KafkaSpout Throws
IllegalStateException After Committing to Kafka When First Poll Strategy
Set to EARLIEST
[ https://issues.apache.org/jira/browse/STORM-2844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Hugo Louro updated STORM-2844:
------------------------------
Description:
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.
was:
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.
> 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)