com.opendxl.databus.common.internal.adapter

Class ConsumerRecordsAdapter<P>

java.lang.Object

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

Type Parameters:

P - payload's type

All Implemented Interfaces:

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

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

Adapter for ConsumerRecords

Constructor Summary

Constructors

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

Method Summary

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerRecordsAdapter

public ConsumerRecordsAdapter(Deserializer<P> messageDeserializer)

Constructor

Parameters:

messageDeserializer - a Deserializer getInstance used for deserializing the payload

Method Detail

adapt

public ConsumerRecords adapt(org.apache.kafka.clients.consumer.ConsumerRecords<java.lang.String,DatabusMessage> sourceConsumerRecords)

Adapter pattern implementation for ConsumerRecords instance. Adapts a DatabusMessage list object for a given topic partition to a ConsumerRecords instance.

Specified by:

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

Parameters:

sourceConsumerRecords - The consumer records source composed by DatabusMessage list instance.

Returns:

a ConsumerRecords instance.