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

Interface MskRecordProcessor<T>

public interface MskRecordProcessor<T>

Method Summary

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

Method Detail

processRecord

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