addressing some review comments for avro format

Signed-off-by: Ning Sun <[email protected]>

Author: sunng87

formats/avro/pom.xml

@@ -33,6 +33,7 @@
 
     <properties>
         <avro.version>1.9.2</avro.version>
+        <build.helper.version>3.2.0</build.helper.version>
         <module-name>io.cloudevents.formats.avro</module-name>
     </properties>
 
@@ -41,7 +42,7 @@
             <plugin>
                 <groupId>org.apache.avro</groupId>
                 <artifactId>avro-maven-plugin</artifactId>
-                <version>1.10.2</version>
+                <version>${avro.version}</version>
                 <executions>
                     <execution>
                         <phase>generate-sources</phase>
@@ -59,7 +60,7 @@
             <plugin>
                 <groupId>org.codehaus.mojo</groupId>
                 <artifactId>build-helper-maven-plugin</artifactId>
-                <version>3.2.0</version>
+                <version>${build.helper.version}</version>
                 <executions>
                     <execution>
                         <id>add-source</id>

formats/avro/src/main/avro/spec.avsc

@@ -1,5 +1,5 @@
 {
-  "namespace":"io.cloudevents",
+  "namespace":"io.cloudevents.avro",
   "type":"record",
   "name":"AvroCloudEvent",
   "version":"1.0",
@@ -61,4 +61,3 @@
     }
   ]
 }
-

formats/avro/src/main/java/io/cloudevents/avro/AvroCloudEventDataWrapper.java

@@ -18,19 +18,19 @@
 
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
-import java.util.List;
 import java.util.Map;
 
-import io.cloudevents.AvroCloudEventData;
+import io.cloudevents.avro.AvroCloudEventData;
 import io.cloudevents.CloudEventData;
+import io.cloudevents.core.format.EventDeserializationException;
 
 /**
  * Encode JSON style cloudevent data into Avro format.
  *
  */
 public class AvroCloudEventDataWrapper implements CloudEventData {
 
-    private AvroCloudEventData avroCloudEventData;
+    private final AvroCloudEventData avroCloudEventData;
 
     /**
      * Wraps a JSON object-like data structure.
@@ -42,13 +42,11 @@ public AvroCloudEventDataWrapper(Map<String, Object> data) {
 
     @Override
     public byte[] toBytes() {
-        ByteArrayOutputStream bytes = new ByteArrayOutputStream();
-        try {
+        try (ByteArrayOutputStream bytes = new ByteArrayOutputStream()) {
             AvroCloudEventData.getEncoder().encode(this.avroCloudEventData, bytes);
-        } catch (IOException ignore) {
-            // ignored
+            return bytes.toByteArray();
+        } catch (IOException e) {
+            throw new EventDeserializationException(e);
         }
-
-        return bytes.toByteArray();
     }
 }

formats/avro/src/main/java/io/cloudevents/avro/AvroDeserializer.java

@@ -24,7 +24,7 @@
 
 import io.cloudevents.CloudEventData;
 import io.cloudevents.SpecVersion;
-import io.cloudevents.AvroCloudEvent;
+import io.cloudevents.avro.AvroCloudEvent;
 import io.cloudevents.core.data.BytesCloudEventData;
 import io.cloudevents.core.v1.CloudEventV1;
 import io.cloudevents.rw.CloudEventRWException;

formats/avro/src/main/java/io/cloudevents/avro/AvroFormat.java

@@ -23,7 +23,7 @@
 
 import io.cloudevents.CloudEvent;
 import io.cloudevents.CloudEventData;
-import io.cloudevents.AvroCloudEvent;
+import io.cloudevents.avro.AvroCloudEvent;
 import io.cloudevents.core.builder.CloudEventBuilder;
 import io.cloudevents.core.format.EventDeserializationException;
 import io.cloudevents.core.format.EventFormat;
@@ -37,23 +37,19 @@ public class AvroFormat implements EventFormat {
     @Override
     public byte[] serialize(CloudEvent event) throws EventSerializationException {
         AvroCloudEvent avroCloudEvent = AvroSerializer.toAvro(event);
-        ByteArrayOutputStream output = new ByteArrayOutputStream();
 
-        try {
+        try (ByteArrayOutputStream output = new ByteArrayOutputStream()) {
             AvroCloudEvent.getEncoder().encode(avroCloudEvent, output);
+            return output.toByteArray();
         } catch (IOException e) {
             throw new EventSerializationException(e);
         }
-
-        return output.toByteArray();
     }
 
     @Override
     public CloudEvent deserialize(byte[] bytes, CloudEventDataMapper<? extends CloudEventData> mapper)
         throws EventDeserializationException {
-        ByteArrayInputStream input = new ByteArrayInputStream(bytes);
-
-         try {
+        try (ByteArrayInputStream input = new ByteArrayInputStream(bytes)) {
              AvroCloudEvent avroCloudEvent = AvroCloudEvent.getDecoder().decode(input);
 
              return new AvroDeserializer(avroCloudEvent).read(CloudEventBuilder::fromSpecVersion, mapper);

formats/avro/src/main/java/io/cloudevents/avro/AvroSerializer.java

@@ -24,11 +24,11 @@
 import io.cloudevents.CloudEvent;
 import io.cloudevents.CloudEventData;
 import io.cloudevents.core.v1.CloudEventV1;
-import io.cloudevents.AvroCloudEvent;
+import io.cloudevents.avro.AvroCloudEvent;
 
 class AvroSerializer {
 
-    public static final AvroCloudEvent toAvro(CloudEvent e) {
+    static final AvroCloudEvent toAvro(CloudEvent e) {
         AvroCloudEvent avroCloudEvent = new AvroCloudEvent();
 
         Map<String, Object> attrs = new HashMap<>();