Package com.amazonaws.athena.connectors.msk.consumer

Interface MskConsumer

All Known Implementing Classes:

BaseMskConsumer, MskAvroConsumer, MskDefaultConsumer, MskProtobufConsumer

public interface MskConsumer

Method Summary

Modifier and Type	Method	Description
void	consume(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker, SplitParameters splitParameters, org.apache.kafka.clients.consumer.Consumer<?,?> kafkaConsumer)	Consume topic data as batch.

Method Detail

consume

void consume(BlockSpiller spiller,
             ReadRecordsRequest recordsRequest,
             QueryStatusChecker queryStatusChecker,
             SplitParameters splitParameters,
             org.apache.kafka.clients.consumer.Consumer<?,?> kafkaConsumer)

Consume topic data as batch.

Parameters:

spiller - - instance of BlockSpiller

recordsRequest - - instance of ReadRecordsRequest

queryStatusChecker - - instance of QueryStatusChecker

splitParameters - - instance of SplitParameters

kafkaConsumer - - instance of KafkaConsumer