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 >>>>> >>>>> >>>>> >>>>> >> >
