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 <laver...@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 >
