public interface  org.apache.drill.exec.store.kafka.decoders.MessageReader extends java.lang.Object implements java.io.Closeable
{
public abstract void init(org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator, org.apache.drill.exec.store.kafka.ReadOptions, org.apache.drill.exec.store.kafka.KafkaStoragePlugin);
public abstract void readMessage(org.apache.kafka.clients.consumer.ConsumerRecord);
public abstract org.apache.kafka.clients.consumer.KafkaConsumer getConsumer(org.apache.drill.exec.store.kafka.KafkaStoragePlugin);
public abstract org.apache.drill.exec.physical.resultSet.ResultSetLoader getResultSetLoader();
public abstract boolean endBatch();
}