P
- payload's typepublic class ConsumerRecordsAdapter<P> extends java.lang.Object implements Adapter<org.apache.kafka.clients.consumer.ConsumerRecords<java.lang.String,DatabusMessage>,ConsumerRecords>
Constructor and Description |
---|
ConsumerRecordsAdapter(Deserializer<P> messageDeserializer)
Constructor
|
Modifier and Type | Method and Description |
---|---|
ConsumerRecords |
adapt(org.apache.kafka.clients.consumer.ConsumerRecords<java.lang.String,DatabusMessage> sourceConsumerRecords)
Adapter pattern implementation for ConsumerRecords instance.
|
public ConsumerRecordsAdapter(Deserializer<P> messageDeserializer)
messageDeserializer
- a Deserializer
getInstance used for deserializing the payloadpublic ConsumerRecords adapt(org.apache.kafka.clients.consumer.ConsumerRecords<java.lang.String,DatabusMessage> sourceConsumerRecords)
adapt
in interface Adapter<org.apache.kafka.clients.consumer.ConsumerRecords<java.lang.String,DatabusMessage>,ConsumerRecords>
sourceConsumerRecords
- The consumer records source composed by DatabusMessage list instance.ConsumerRecords
instance.