Could you double check that you used the correct topic name? If so, could you run ConsumerOffsetChecker as described in https://cwiki.apache.org/confluence/display/KAFKA/FAQ and see if there is any lag?
Thanks, Jun On Tue, Feb 11, 2014 at 8:45 AM, Arjun Kota <ar...@socialtwist.com> wrote: > fetch.wait.max.ms=10000 > fetch.min.bytes=128 > > My message size is much more than that. > On Feb 11, 2014 9:21 PM, "Jun Rao" <jun...@gmail.com> wrote: > > > What's the fetch.wait.max.ms and fetch.min.bytes you used? > > > > Thanks, > > > > Jun > > > > > > On Tue, Feb 11, 2014 at 12:54 AM, Arjun <ar...@socialtwist.com> wrote: > > > > > With the same group id from the console consumer its working fine. > > > > > > > > > On Tuesday 11 February 2014 01:59 PM, Guozhang Wang wrote: > > > > > >> Arjun, > > >> > > >> Are you using the same group name for the console consumer and the > java > > >> consumer? > > >> > > >> Guozhang > > >> > > >> > > >> On Mon, Feb 10, 2014 at 11:38 PM, Arjun <ar...@socialtwist.com> > wrote: > > >> > > >> Hi Jun, > > >>> > > >>> No its not that problem. I am not getting what the problem is can you > > >>> please help. > > >>> > > >>> thanks > > >>> Arjun Narasimha Kota > > >>> > > >>> > > >>> On Monday 10 February 2014 09:10 PM, Jun Rao wrote: > > >>> > > >>> Does > > >>>> https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ- > > >>>> Whydoesmyconsumernevergetanydata? > > >>>> apply? > > >>>> > > >>>> Thanks, > > >>>> > > >>>> Jun > > >>>> > > >>>> > > >>>> On Sun, Feb 9, 2014 at 10:27 PM, Arjun <ar...@socialtwist.com> > wrote: > > >>>> > > >>>> Hi, > > >>>> > > >>>>> I started using kafka some time back. I was experimenting with 0.8. > > My > > >>>>> problem is the kafka is unable to consume the messages. My > > >>>>> configuration > > >>>>> is kafka broker on the local host and zookeeper on the local host. > I > > >>>>> have only one broker and one consumer at present. > > >>>>> > > >>>>> What have I done: > > >>>>> 1) I used the java examples in the kafka src and pushed some > > 600 > > >>>>> messages to the broker > > >>>>> 2) I used the console consumer to check weather the messages > > are > > >>>>> there in the broker or not. Console consumer printed all 600 > messages > > >>>>> 3) Now i used the java Consumer code, and tried to get those > > >>>>> messages. This is not printing any messages. It just got stuck > > >>>>> > > >>>>> When was it working earlier: > > >>>>> -When i tried with three brokers and three consumers in the > > same > > >>>>> machine, with the same configuration it worked fine. > > >>>>> -I changed the properties accordingly when i tried to make > it > > >>>>> work > > >>>>> with one broker and one consumer > > >>>>> > > >>>>> What does log say: > > >>>>> - attaching the logs even > > >>>>> > > >>>>> If some one points me where I am doing wrong it would be helpful. > > >>>>> > > >>>>> Thanks > > >>>>> Arjun Narasimha Kota > > >>>>> > > >>>>> > > >>>>> > > >>>>> > > >> > > > > > >
