Re: Empty topic/partition timeout when consuming

2013-10-21 Thread gmail
That was the problem. Thanks Jun! -Robert > On Oct 21, 2013, at 9:25 PM, Jun Rao wrote: > > Did you set the socket timeout to be larger than the maxWait time in the > fetch request? > > Thanks, > > Jun > > >> On Mon, Oct 21, 2013 at 9:02 PM, Robert W wrote: >> >> I notice that when usi

Re: Empty topic/partition timeout when consuming

2013-10-21 Thread Jun Rao
Did you set the socket timeout to be larger than the maxWait time in the fetch request? Thanks, Jun On Mon, Oct 21, 2013 at 9:02 PM, Robert W wrote: > I notice that when using the SimpleConsumer javaapi and trying to consume > from an existing topic and partition that has never been written t

Empty topic/partition timeout when consuming

2013-10-21 Thread Robert W
I notice that when using the SimpleConsumer javaapi and trying to consume from an existing topic and partition that has never been written to before, I get a SocketTimeoutException. Is there a way around this? I'm using kafka-0.8.0 beta1. Thanks, -Robert