We are facing a similar problem. Randomly the spout stops consuming the messages from the Kafka topic. A restart of the topology makes it to start consuming again.
Any help here is appreciated. Thanks Rahul On Thu, Jul 21, 2016 at 6:14 PM -0700, "Yaroslav Chinskiy" <[email protected]<mailto:[email protected]>> wrote: Hi, I have an issue where KafkaSpout randomly stops processing messages. I am using the old implementation not storm-kaka-client I use Kafka 0.10 and Storm 1.0.1. I have 3 node cluster with 4 spouts across. To test the issue I stream 10M messages to Kafka and consume them with KafkaSpout. The issue is random and I am not sure where to start investigation. Any help to understand the issue and start investigation is highly appreciated. My experience is similar to what is reported here http://stackoverflow.com/questions/38198961/storm-kafkaspout-stopped-to-consume-messages-from-kafka-topic Thank you Yarik.
