Hi Everyone,

I have a topology with a KafkaSpout and the KafkaSpout executor keeps
restarting repeatedly with no error message. Basically I see messages in
the log where it relaunches the worker hosting the KafkaSpout executor.

Is this a problem with my offset logic?  I am running out of ideas at this
point, so if anyone has any thoughts, I'd appreciate it. :)

Thanks

--John

Reply via email to