Empty Queue

[sebastian-alfers]

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]

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: #11