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.
