This code, which was committed to fix 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.