Empty Queue

Open sebastian-alfers opened this issue 10 years ago • 1 comments

I there away to continue the AkkaConsumer when the queue becomes empty?

DEBUG] [08/12/2015 15:57:06.364] [base-actor-system-akka.actor.default-dispatcher-3] [akka://base-actor-system/user/$a/stream0] stream=stream0 at=transition from=Processing to=Unused

in my case, it stops and even when the queue gets new messages, it does not continue i tried with stop / start it keeps idle

Aug 12 '15 14:08 sebastian-alfers

I assume ZK still holds an offset for your consumer and thus the consumer won't consume before your queue reaches the amount of messages higher than this offset.

See: https://github.com/sclasen/akka-kafka/issues/11

Sep 30 '15 07:09 mjuchli