com.opendxl.databus.common.internal.adapter

Class ConsumerRecordAdapter<P>

java.lang.Object

com.opendxl.databus.common.internal.adapter.ConsumerRecordAdapter<P>

All Implemented Interfaces:

Adapter<org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,DatabusMessage>,ConsumerRecord<P>>

public final class ConsumerRecordAdapter<P>
extends java.lang.Object
implements Adapter<org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,DatabusMessage>,ConsumerRecord<P>>

Adapter for ConsumerRecord.

Constructor Summary

Constructors

Constructor and Description
ConsumerRecordAdapter(Deserializer<P> messageDeserializer) Constructor

Method Summary

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerRecordAdapter

public ConsumerRecordAdapter(Deserializer<P> messageDeserializer)

Constructor

Parameters:

messageDeserializer - a Deserializer getInstance getInstance used for deserialize the payload.

Method Detail

adapt

public ConsumerRecord<P> adapt(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,DatabusMessage> sourceConsumerRecord)

Adapter pattern implementation for ConsumerRecord. Adapts a DatabusMessage object to a ConsumerRecord.

Specified by:

adapt in interface Adapter<org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,DatabusMessage>,ConsumerRecord<P>>

Parameters:

sourceConsumerRecord - the ConsumerRecord to be adapted.

Returns:

A Databus ConsumerRecord