search

sclasen / akka-kafka

185 stars 62 forks source link

Empty Queue #40

Open sebastian-alfers opened 9 years ago

sebastian-alfers commented 9 years ago

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

mjuchli commented 9 years ago

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