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

Class MskDefaultConsumer

java.lang.Object

com.amazonaws.athena.connectors.msk.consumer.BaseMskConsumer<TopicResultSet>

com.amazonaws.athena.connectors.msk.consumer.MskDefaultConsumer

All Implemented Interfaces:

MskConsumer

public class MskDefaultConsumer
extends BaseMskConsumer<TopicResultSet>

Field Summary

Fields inherited from class com.amazonaws.athena.connectors.msk.consumer.BaseMskConsumer

MAX_EMPTY_RESULT_FOUND_COUNT

Constructor Summary

Constructors

Constructor	Description
MskDefaultConsumer()

Method Summary

Modifier and Type	Method	Description
protected void	processRecord(BlockSpiller spiller, SplitParameters splitParameters, org.apache.kafka.clients.consumer.ConsumerRecord<String,TopicResultSet> record)

Methods inherited from class com.amazonaws.athena.connectors.msk.consumer.BaseMskConsumer

consume

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MskDefaultConsumer

public MskDefaultConsumer()

Method Detail

processRecord

protected void processRecord(BlockSpiller spiller,
                             SplitParameters splitParameters,
                             org.apache.kafka.clients.consumer.ConsumerRecord<String,TopicResultSet> record)

Specified by:

processRecord in class BaseMskConsumer<TopicResultSet>