[Avro] Add support for @AvroMeta annotation

Author: baharclerode

avro/src/main/java/com/fasterxml/jackson/dataformat/avro/schema/RecordVisitor.java

@@ -15,6 +15,7 @@
 import com.fasterxml.jackson.dataformat.avro.AvroFixedSize;
 
 import org.apache.avro.Schema;
+import org.apache.avro.reflect.AvroMeta;
 import org.apache.avro.reflect.AvroSchema;
 
 public class RecordVisitor
@@ -47,6 +48,10 @@ public RecordVisitor(SerializerProvider p, JavaType type, DefinedSchemas schemas
             String description = getProvider().getAnnotationIntrospector().findClassDescription(ac);
             _avroSchema = Schema.createRecord(AvroSchemaHelper.getName(type), description, AvroSchemaHelper.getNamespace(type), false);
             _overridden = false;
+            AvroMeta meta = ac.getAnnotation(AvroMeta.class);
+            if (meta != null) {
+                _avroSchema.addProp(meta.key(), meta.value());
+            }
         }
         schemas.addSchema(type, _avroSchema);
     }
@@ -159,6 +164,13 @@ protected Schema.Field schemaFieldForWriter(BeanProperty prop, boolean optional)
             }
         }
         String description = getProvider().getAnnotationIntrospector().findPropertyDescription(prop.getMember());
-        return new Schema.Field(prop.getName(), writerSchema, description, null);
+        Schema.Field field = new Schema.Field(prop.getName(), writerSchema, description, null);
+
+        AvroMeta meta = prop.getAnnotation(AvroMeta.class);
+        if (meta != null) {
+            field.addProp(meta.key(), meta.value());
+        }
+
+        return field;
     }
 }

avro/src/test/java/com/fasterxml/jackson/dataformat/avro/interop/annotations/AvroMetaTest.java

@@ -0,0 +1,77 @@
+package com.fasterxml.jackson.dataformat.avro.interop.annotations;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.dataformat.avro.interop.InteropTestBase;
+
+import lombok.Data;
+import org.apache.avro.AvroRuntimeException;
+import org.apache.avro.Schema;
+import org.apache.avro.reflect.AvroMeta;
+import org.apache.avro.reflect.AvroSchema;
+import org.junit.Test;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+public class AvroMetaTest extends InteropTestBase {
+
+    @Data
+    @AvroMeta(key = "class-meta", value = "class value")
+    static class MetaTest {
+
+        @AvroMeta(key = "custom Property", value = "Some Value")
+        private String someProperty;
+
+        @AvroMeta(key = "required custom Property", value = "Some required Value")
+        @JsonProperty(required = true)
+        private String someRequiredProperty;
+    }
+
+    @Data
+    static class BadMetaTest {
+
+        @AvroMeta(key = "name", value = "colliding property")
+        private String types;
+    }
+
+    @Data
+    @AvroSchema("{\"type\":\"string\"}")
+    @AvroMeta(key="overridden", value = "true")
+    static class OverriddenClassSchema {
+
+        private int field;
+    }
+
+    @Test
+    public void testAnnotationPrecedence() {
+        Schema schema = schemaFunctor.apply(OverriddenClassSchema.class);
+        //
+        assertThat(schema.getProp("overridden")).isNull();
+    }
+
+    @Test
+    public void testOptionalFieldMetaProperty() {
+        Schema schema = schemaFunctor.apply(MetaTest.class);
+        //
+        assertThat(schema.getField("someProperty").getProp("custom Property")).isEqualTo("Some Value");
+    }
+
+    @Test
+    public void testRequiredFieldMetaProperty() {
+        Schema schema = schemaFunctor.apply(MetaTest.class);
+        //
+        assertThat(schema.getField("someRequiredProperty").getProp("required custom Property")).isEqualTo("Some required Value");
+    }
+
+    @Test
+    public void testClassMetaProperty() {
+        Schema schema = schemaFunctor.apply(MetaTest.class);
+        //
+        assertThat(schema.getProp("class-meta")).isEqualTo("class value");
+    }
+
+    @Test(expected = AvroRuntimeException.class)
+    public void testCollidingMeta() {
+        schemaFunctor.apply(BadMetaTest.class);
+    }
+
+}