[STORM-2211] KafkaSpout error after recreating kafka topic

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.0.1
• Component/s: storm-kafka
• Assignee: Unassigned
• Reporter: Alexey Ignatov
• Created: 21/Nov/16 20:11
• Updated: 21/Nov/16 20:11

Description

I have a storm topology with a KakfaSpout which was processing messages successfully. I shut down the topology, deleted the kafka topic and recreated it. After restarting the topology, it appears storm saved the partition in zookeeper and was unable to identify that the partition no longer existed. I saw the following error message in the storm logs:

o.a.s.k.KafkaUtils [WARN] Partition

{host=<removed>, topic=<removed>, partition=0}

Got fetch request with offset out of range: [10650]