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