public final class ConsumerRecordAdapter<P> extends java.lang.Object implements Adapter<org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,DatabusMessage>,ConsumerRecord<P>>
Constructor and Description |
---|
ConsumerRecordAdapter(Deserializer<P> messageDeserializer)
Constructor
|
Modifier and Type | Method and Description |
---|---|
ConsumerRecord<P> |
adapt(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,DatabusMessage> sourceConsumerRecord)
Adapter pattern implementation for ConsumerRecord.
|
public ConsumerRecordAdapter(Deserializer<P> messageDeserializer)
messageDeserializer
- a Deserializer
getInstance getInstance used for deserialize the payload.public ConsumerRecord<P> adapt(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,DatabusMessage> sourceConsumerRecord)
adapt
in interface Adapter<org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,DatabusMessage>,ConsumerRecord<P>>
sourceConsumerRecord
- the ConsumerRecord to be adapted.ConsumerRecord