Apache Kafka: exception causing session <xx> to close due to java.io.IOException: unreasonable length

Question

Apache Kafka 0.9.0

I get the above exception in the zookeeper log when trying to fetch through a user. This is how I create a consumer query:

kafka.api.FetchRequest req = new FetchRequestBuilder().clientId(clientId)
                                                      .addFetch(topic, 0, 0L, 100)
                                                      .build();
FetchResponse fetchResponse = simpleConsumer.fetch(req);

I see a java.io.EOFExceptionwhen the consumer is fetching.

Any thoughts ??