public class StructuredSerializer<T> extends Serializer<T>
builder
Constructor and Description |
---|
StructuredSerializer(io.cloudevents.fun.EnvelopeMarshaller<io.cloudevents.v1.AttributesImpl,T,byte[]> dataMarshaller) |
Modifier and Type | Method and Description |
---|---|
protected io.cloudevents.format.builder.EventStep<io.cloudevents.v1.AttributesImpl,T,byte[],byte[]> |
structuredBuilder(io.cloudevents.fun.EnvelopeMarshaller<io.cloudevents.v1.AttributesImpl,T,byte[]> dataMarshaller)
The default Kafka Marshallers do not provide hooks to customize the marshalling the cloudevent
payload and custom extensions.
|
producerRecord, producerRecord, serialize, toString
public StructuredSerializer(io.cloudevents.fun.EnvelopeMarshaller<io.cloudevents.v1.AttributesImpl,T,byte[]> dataMarshaller)
protected io.cloudevents.format.builder.EventStep<io.cloudevents.v1.AttributesImpl,T,byte[],byte[]> structuredBuilder(io.cloudevents.fun.EnvelopeMarshaller<io.cloudevents.v1.AttributesImpl,T,byte[]> dataMarshaller)