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

Class MskProtobufConsumer

java.lang.Object

com.amazonaws.athena.connectors.msk.consumer.BaseMskConsumer<com.google.protobuf.DynamicMessage>

com.amazonaws.athena.connectors.msk.consumer.MskProtobufConsumer

All Implemented Interfaces:

MskConsumer

public class MskProtobufConsumer
extends BaseMskConsumer<com.google.protobuf.DynamicMessage>

Field Summary

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

MAX_EMPTY_RESULT_FOUND_COUNT

Constructor Summary

Constructors

Constructor	Description
MskProtobufConsumer()

Method Summary

Modifier and Type	Method	Description
protected void	processRecord(BlockSpiller spiller, SplitParameters splitParameters, org.apache.kafka.clients.consumer.ConsumerRecord<String,com.google.protobuf.DynamicMessage> 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

MskProtobufConsumer

public MskProtobufConsumer()

Method Detail

processRecord

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

Specified by:

processRecord in class BaseMskConsumer<com.google.protobuf.DynamicMessage>