P
- payload's typepublic final class DatabusProducerRecordAdapter<P> extends java.lang.Object implements Adapter<ProducerRecord,org.apache.kafka.clients.producer.ProducerRecord<java.lang.String,DatabusMessage>>
Constructor and Description |
---|
DatabusProducerRecordAdapter(Serializer<P> messageSerializer)
Constructor
|
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.
|
public DatabusProducerRecordAdapter(Serializer<P> messageSerializer)
messageSerializer
- a Serializer
instance used for Serializing the payload.public org.apache.kafka.clients.producer.ProducerRecord<java.lang.String,DatabusMessage> adapt(ProducerRecord sourceProducerRecord)
adapt
in interface Adapter<ProducerRecord,org.apache.kafka.clients.producer.ProducerRecord<java.lang.String,DatabusMessage>>
sourceProducerRecord
- a ProducerRecord
instance.