public abstract class Serializer<T>
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected io.cloudevents.format.builder.EventStep<io.cloudevents.v1.AttributesImpl,T,byte[],byte[]> |
builder |
Constructor and Description |
---|
Serializer() |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.producer.ProducerRecord<java.lang.String,byte[]> |
producerRecord(io.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T> event,
java.lang.String topic,
java.lang.Integer partition) |
org.apache.kafka.clients.producer.ProducerRecord<java.lang.String,byte[]> |
producerRecord(io.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T> event,
java.lang.String topic,
java.lang.Integer partition,
java.lang.String key) |
byte[] |
serialize(io.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T> event) |
java.lang.String |
toString(io.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T> event) |
protected io.cloudevents.format.builder.EventStep<io.cloudevents.v1.AttributesImpl,T,byte[],byte[]> builder
public byte[] serialize(io.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T> event)
public java.lang.String toString(io.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T> event)
public org.apache.kafka.clients.producer.ProducerRecord<java.lang.String,byte[]> producerRecord(io.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T> event, java.lang.String topic, java.lang.Integer partition)
public org.apache.kafka.clients.producer.ProducerRecord<java.lang.String,byte[]> producerRecord(io.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T> event, java.lang.String topic, java.lang.Integer partition, java.lang.String key)