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 <hussain.piro...@impetus.co.in> 
> wrote:
> 
> 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.com/hpirosha/8456360.
> 
> The same thing works if I use the code from kafka.consumer.ConsoleConsumer. 
> Difference between them is using the 
> ConsumerConnector#createMessageStreamsByFilter while the high level consumer
> invokes the ConsumerConnector#createMessageStreams api. Has the former api 
> got broken or the wiki is not up-to-date ?
> 
> Pardon me if this has been already discussed in the group.
> 
> Thanks,
> Hussain
> 
> ________________________________
> 
> 
> 
> 
> 
> 
> NOTE: This message may contain information that is confidential, proprietary, 
> privileged or otherwise protected by law. The message is intended solely for 
> the named addressee. If received in error, please destroy and notify the 
> sender. Any use of this email is prohibited when received in error. Impetus 
> does not represent, warrant and/or guarantee, that the integrity of this 
> communication has been maintained nor that the communication is free of 
> errors, virus, interception or interference.

Reply via email to