com.opendxl.databus.common.internal.adapter

Class DatabusProducerRecordAdapter<P>

java.lang.Object

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

Type Parameters:

P - payload's type

All Implemented Interfaces:

Adapter<ProducerRecord,org.apache.kafka.clients.producer.ProducerRecord<java.lang.String,DatabusMessage>>

public final class DatabusProducerRecordAdapter<P>
extends java.lang.Object
implements Adapter<ProducerRecord,org.apache.kafka.clients.producer.ProducerRecord<java.lang.String,DatabusMessage>>

Adapter for Databus Producer Record

Constructor Summary

Constructors

Constructor and Description
DatabusProducerRecordAdapter(Serializer<P> messageSerializer) Constructor

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.clients.producer.ProducerRecord<java.lang.String,DatabusMessage>	adapt(ProducerRecord sourceProducerRecord) Adapter pattern implementation for DatabusProducerRecord instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

DatabusProducerRecordAdapter

public DatabusProducerRecordAdapter(Serializer<P> messageSerializer)

Constructor

Parameters:

messageSerializer - a Serializer instance used for Serializing the payload.

Method Detail

adapt

public org.apache.kafka.clients.producer.ProducerRecord<java.lang.String,DatabusMessage> adapt(ProducerRecord sourceProducerRecord)

Adapter pattern implementation for DatabusProducerRecord instance. Adapts a ProducerRecord to a DatabusProducerRecord instance.

Specified by:

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

Parameters:

sourceProducerRecord - a ProducerRecord instance.

Returns:

a DatabusProducerRecord with a String key and a DatabusMessage value.