public class StructuredDeserializer<T> extends Deserializer<T>
builder
Constructor and Description |
---|
StructuredDeserializer(java.util.function.Function<byte[],io.cloudevents.v1.CloudEventImpl<T>> structuredUnmarshaller) |
Modifier and Type | Method and Description |
---|---|
protected io.cloudevents.format.builder.HeadersStep<io.cloudevents.v1.AttributesImpl,T,byte[]> |
structuredBuilder(java.util.function.Function<byte[],io.cloudevents.v1.CloudEventImpl<T>> structuredUnmarshaller)
The default Kafka UnMarshallers do not provide hooks to customize the unmarshalling of the
cloudevent payload and custom extensions.
|
deserialize, deserialize
public StructuredDeserializer(java.util.function.Function<byte[],io.cloudevents.v1.CloudEventImpl<T>> structuredUnmarshaller)
protected io.cloudevents.format.builder.HeadersStep<io.cloudevents.v1.AttributesImpl,T,byte[]> structuredBuilder(java.util.function.Function<byte[],io.cloudevents.v1.CloudEventImpl<T>> structuredUnmarshaller)