You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Mike Thomsen <mi...@gmail.com> on 2014/10/14 13:41:30 UTC

Kafka spout stops processing data

When we deploy a topology that uses the kafka spout (we're on 0.9.2 and
using the bundled spout), it seems to only pull the messages that were
there when it started. So if we have 5,000 messages already in, but are
pushing more into the queue as it deploys, it seems to only grab those
first 5,000 messages. When we redeploy, it finds the new messages.

Any ideas on what is happening here?

Thanks,

Mike