You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Robert W <la...@gmail.com> on 2013/10/22 06:02:31 UTC

Empty topic/partition timeout when consuming

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

Re: Empty topic/partition timeout when consuming

Posted by gmail <la...@gmail.com>.

That was the problem.  Thanks Jun!

-Robert



> On Oct 21, 2013, at 9:25 PM, Jun Rao <ju...@gmail.com> 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 <la...@gmail.com> wrote:
>> 
>> 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
>>

Re: Empty topic/partition timeout when consuming

Posted by Jun Rao <ju...@gmail.com>.

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 <la...@gmail.com> wrote:

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