diff --git a/core/src/main/java/io/cloudevents/core/format/ContentType.java b/core/src/main/java/io/cloudevents/core/format/ContentType.java index 1d8656393..c5b19f883 100644 --- a/core/src/main/java/io/cloudevents/core/format/ContentType.java +++ b/core/src/main/java/io/cloudevents/core/format/ContentType.java @@ -45,6 +45,10 @@ public enum ContentType { * The content type for transports sending cloudevents in the protocol buffer format. */ PROTO("application/cloudevents+protobuf"), + /** + * The content type for transports sending cloudevents in the compact Avro format. + */ + AVRO_COMPACT("application/cloudevents+avrocompact"), /** * The content type for transports sending cloudevents in XML format. */ diff --git a/formats/avro-compact/src/test/java/io/cloudevents/avro/compact/AvroCompactFormatTest.java b/formats/avro-compact/src/test/java/io/cloudevents/avro/compact/AvroCompactFormatTest.java index e87657bc2..484ab15f9 100644 --- a/formats/avro-compact/src/test/java/io/cloudevents/avro/compact/AvroCompactFormatTest.java +++ b/formats/avro-compact/src/test/java/io/cloudevents/avro/compact/AvroCompactFormatTest.java @@ -28,6 +28,7 @@ import java.time.ZoneOffset; import java.util.Collections; +import static org.junit.jupiter.api.Assertions.assertArrayEquals; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertNotNull; @@ -67,5 +68,10 @@ void format() { assertEquals(event, deserialized); + byte[] reserialized = format.serialize(deserialized); + + assertArrayEquals(serialized, reserialized); + + } }