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
