Hi,

I am using storm 0.9.0.1, kafka 0.8, and storm-kafka-0.8-plus.  In 
LocalCluster, after fetching and processing about 18,000 messages, the spout 
stops fetching from Kafka even though there are new messages in the queue.
There are no errors in the storm or kafka logs.  Any idea why this is happening?

Thanks,
Jing

Reply via email to