nathanmarz/storm-contrib — pull request #15 by binhnv (2012-09-28 17:30:42+00:00)
Title: Fix out of range exception issue of partitioned Kafka spout

I modified KafkaUtils::emitPartitionBatchNew method to fix the out of range exception when fetch messages from Kafka's topic.
This issue happens when there is no previous status in Zookeeper and the beginning offset of Kafka's brokers is non-zero.

-Binh