Package org.apache.drill.exec.store.kafka.decoders

Interface MessageReader

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

AvroMessageReader, JsonMessageReader

public interface MessageReader
extends Closeable

MessageReader interface provides mechanism to handle various Kafka Message Formats like JSON, AVRO or custom message formats.

Method Summary

Modifier and Type	Method	Description
boolean	endBatch()
org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]>	getConsumer(KafkaStoragePlugin plugin)
ResultSetLoader	getResultSetLoader()
void	init(SchemaNegotiator negotiator, ReadOptions readOptions, KafkaStoragePlugin plugin)
void	readMessage(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> message)

Methods inherited from interface java.io.Closeable

close

Method Details

init

void init(SchemaNegotiator negotiator,
 ReadOptions readOptions,
 KafkaStoragePlugin plugin)

readMessage

void readMessage(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> message)

getConsumer

org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]> getConsumer(KafkaStoragePlugin plugin)

getResultSetLoader

ResultSetLoader getResultSetLoader()

endBatch

boolean endBatch()