Thanks for the quick response. I am using Storm 1.0.2 and the storm-kafka version is 1.0.2 as well. The kafka version being used is 2.9.2 - 0.8.1.1
On Thu, Feb 23, 2017 at 3:04 AM, P. Taylor Goetz <ptgo...@gmail.com> wrote: > What version of Storm are you using? And which Kafka spout (i.e. > storm-kafka or storm-kafka-client)? > > -Taylor > > On Feb 22, 2017, at 4:32 PM, Abhishek Raj <abhishek....@saavn.com> wrote: > > Hello, I am using storm's state management feature in a topology. > The topology has a kafkaspout and a StatefulBolt which uses > RedisKeyValueState. What I observe is that after some time of running > smoothly, the spout just stops consuming from the kafka topic and > the $checkpointspout stops emitting any checkpoint tuples. The topology > just hangs and there are no error messages in the logs. The spout acts as > if there are no more messages to consume even though there are. This > happens very randomly and if I restart the topology the error may or may > not come. > > Can anyone please help in debugging this? I tried searching on jira but > couldn't find a bug related to this issue. > > Thanks, > > -- > Abhishek > > > -- Abhishek
