Traffic Post On Instagram

import io.cloudevents.CloudEvent; import io.cloudevents.extensions.ExtensionFormat; import io.cloudevents.format.StructuredMarshaller; import io.cloudevents.format.Wire; import io.cloudevents.format.builder.EventStep; import io.cloudevents.json.Json; import io.cloudevents.v1.Accessor; import io.cloudevents.v1.AttributesImpl; import io.cloudevents.v1.CloudEventBuilder; import io.cloudevents.v1.kafka.HeaderMapper; import org.junit.Test; import java.net.URI; import java.net.URISyntaxException; import java.time.ZonedDateTime; import java.util.UUID; public class ATest { public static class Amount { private int a; public Amount() {} public Amount(int a) { this.a = a; } public int getA() { return a; } public void setA(int a) { this.a = a; } } @Test public void test1() throws URISyntaxException { Amount payload = new Amount(1); CloudEvent<AttributesImpl, Amount> event = CloudEventBuilder.<Amount>builder() .withId(UUID.randomUUID().toString()) .withTime(ZonedDateTime.now()) .withDataContentType("application/cloudevent+json") .withDataschema(new URI("structured_schema")) .withSource(new URI("structured_source")) .withSubject("structured_subject") .withData(payload) .withType("structured_type") .build(); EventStep<AttributesImpl, Amount, byte[], byte[]> builder = StructuredMarshaller.<AttributesImpl, Amount, byte[], byte[]>builder() .mime("Content-Type", "application/cloudevents+json".getBytes()) .map((e) -> Json.binaryEncode(e)) .map(Accessor::extensionsOf) .map(ExtensionFormat::marshal) .map(HeaderMapper::map); Wire<byte[], String, byte[]> wire = builder.withEvent(() -> event).marshal(); System.err.println(new String(wire.getPayload().get())); } } 

{ "data": { "a": 1 }, "id": "88f599ed-e684-4746-a545-5abdd01ac3a5", "source": "structured_source", "specversion": "1.0", "type": "structured_type", "datacontenttype": "application/cloudevent+json", "dataschema": "structured_schema", "subject": "structured_subject", "time": "2019-11-20T14:03:53.613+01:00", "data": { "a": 1 } }