che.org
> Subject: Re: High level consumer does not consumes in 0.8.0 version
>
> By default, a new consumer consumes from the end of the queue, ie. only
> newly produced messages will be consumed. Try producing some more messages
> after the consumer is up or setting the consumer p
level consumer does not consumes in 0.8.0 version
By default, a new consumer consumes from the end of the queue, ie. only newly
produced messages will be consumed. Try producing some more messages after the
consumer is up or setting the consumer property to consume from the beginning.
You shouldn'
By default, a new consumer consumes from the end of the queue, ie. only
newly produced messages will be consumed. Try producing some more messages
after the consumer is up or setting the consumer property to consume from
the beginning. You shouldn't need to commit offset on every message, which
is
We need to try the one with filters, thanks. We found that if you
commitOffsets, after each msg, it works. The IO is not bad.
- charlie
> On Jan 16, 2014, at 8:14 AM, Hussain Pirosha
> wrote:
>
> Hello,
>
> While running the high level consumer mentioned on
> https://cwiki.apache.org/conf
Hello,
While running the high level consumer mentioned on
https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example using
0.8.0 release.
The consumer does not receive any messages and blocks on stream.hasNext() call.
I have pasted the client side logs at
https://gist.github.co
