interface  org.apache.kafkaesqueesqueesque.common.record.LogInputStream extends java.lang.Object
{
public abstract org.apache.kafkaesqueesqueesque.common.record.RecordBatch nextBatch() throws java.io.IOException;
}