More API updates

sdk/schemaregistry/azure-data-schemaregistry-avro/src/main/java/com/azure/data/schemaregistry/avro/AvroSchemaRegistryCodec.java

@@ -22,7 +22,7 @@
  * Base Codec class for Avro encoder and decoder implementations
  */
 public class AvroSchemaRegistryCodec implements SchemaRegistryCodec {
-    private final ClientLogger logger = new ClientLogger(AvroCodec.class);
+    private final ClientLogger logger = new ClientLogger(AvroSchemaRegistryCodec.class);
     private static final EncoderFactory ENCODER_FACTORY = EncoderFactory.get();
     private static final DecoderFactory DECODER_FACTORY = DecoderFactory.get();
     private static final Boolean AVRO_SPECIFIC_READER_DEFAULT = false;
@@ -124,6 +124,7 @@ public byte[] encode(Object object) {
      * @return deserialized object
      * @throws SerializationException upon deserialization failure
      */
+    @Override
     public Object decode(byte[] b, Object object) {
         Objects.requireNonNull(object, "Schema must not be null.");
 

sdk/schemaregistry/azure-data-schemaregistry-avro/src/main/java/com/azure/data/schemaregistry/avro/SchemaRegistryAvroAsyncSerializer.java

@@ -16,7 +16,7 @@
 /**
  * Asynchronous registry-based serializer implementation.
  */
-public class SchemaRegistryAvroAsyncSerializer extends SchemaRegistrySerializer implements ObjectSerializer {
+public final class SchemaRegistryAvroAsyncSerializer extends SchemaRegistrySerializer implements ObjectSerializer {
     private final ClientLogger logger = new ClientLogger(SchemaRegistryAvroAsyncSerializer.class);
 
     /**

sdk/schemaregistry/azure-data-schemaregistry-avro/src/main/java/com/azure/data/schemaregistry/avro/SchemaRegistryAvroSerializer.java

@@ -19,7 +19,7 @@
  *
  * @see SchemaRegistrySerializer See AbstractSchemaRegistrySerializer for internal serialization implementation
  */
-public class SchemaRegistryAvroSerializer {
+public final class SchemaRegistryAvroSerializer {
     private final SchemaRegistryAvroAsyncSerializer serializer;
     SchemaRegistryAvroSerializer(SchemaRegistryAvroAsyncSerializer serializer) {
         this.serializer = serializer;
@@ -31,7 +31,7 @@ public class SchemaRegistryAvroSerializer {
      * @return byte array containing unique ID reference to schema, then the object serialized into bytes
      * @throws SerializationException Throws on serialization failure.
      */
-    public byte[] serialize(Object object) throws SerializationException {
+    public byte[] serialize(Object object) {
         if (object == null) {
             return null;
         }
@@ -53,8 +53,8 @@ public byte[] serialize(Object object) throws SerializationException {
      * @throws SerializationException Throws on deserialization failure.
      * Exception may contain inner exceptions detailing failure condition.
      */
-    public Object deserialize(byte[] data) throws SerializationException {
-        return serializer.deserialize(new ByteArrayInputStream(data), Object.class);
+    public <T> T deserialize(byte[] data, Class<T> clazz) {
+        return serializer.deserialize(new ByteArrayInputStream(data), clazz).block();
     }
 }