public class Unmarshallers
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static <T extends com.google.protobuf.Message> |
binaryProto(T instance) |
static <T extends com.google.protobuf.Message,A extends io.cloudevents.Attributes> |
binaryUmarshaller(T instance) |
static <T> io.cloudevents.format.builder.HeadersStep<io.cloudevents.v03.AttributesImpl,T,byte[]> |
structuredProto(java.lang.Class<T> typeOfData)
Builds a Structured Content Mode unmarshaller to unmarshal JSON as CloudEvents data for Kafka
Transport Binding
|
public static <T extends com.google.protobuf.Message,A extends io.cloudevents.Attributes> io.cloudevents.fun.DataUnmarshaller<byte[],T,A> binaryUmarshaller(T instance)
public static <T extends com.google.protobuf.Message> io.cloudevents.format.builder.HeadersStep<io.cloudevents.v03.AttributesImpl,T,byte[]> binaryProto(T instance)
public static <T> io.cloudevents.format.builder.HeadersStep<io.cloudevents.v03.AttributesImpl,T,byte[]> structuredProto(java.lang.Class<T> typeOfData)
T
- The 'data' typetypeOfData
- The type reference to use for 'data' unmarshalStructuredUnmarshaller