Hugo Louro created STORM-2844:
---------------------------------
Summary: 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
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)
