remove unused AvroCodec

Makefile

@@ -20,7 +20,7 @@
 IMAGE_NAME = pulsar-client-go-test:latest
 PULSAR_VERSION ?= 3.2.2
 PULSAR_IMAGE = apachepulsar/pulsar:$(PULSAR_VERSION)
-GO_VERSION ?= 1.18
+GO_VERSION ?= 1.20
 CONTAINER_ARCH ?= $(shell uname -m | sed s/x86_64/amd64/)
 
 # Golang standard bin directory.

pulsar/schema.go

@@ -125,20 +125,10 @@ func NewSchema(schemaType SchemaType, schemaData []byte, properties map[string]s
 	return
 }
 
-type AvroCodec struct {
-	Codec avro.Schema
-}
-
-func NewSchemaDefinition(schema avro.Schema) *AvroCodec {
-	return &AvroCodec{
-		Codec: schema,
-	}
-}
-
 // initAvroCodec returns a Codec used to translate between a byte slice of either
 // binary or textual Avro data and native Go data.
-func initAvroCodec(codec string) (avro.Schema, error) {
-	return avro.Parse(codec)
+func initAvroCodec(schemaDef string) (avro.Schema, error) {
+	return avro.Parse(schemaDef)
 }
 
 type JSONSchema struct {
@@ -162,8 +152,7 @@ func NewJSONSchemaWithValidation(jsonAvroSchemaDef string, properties map[string
 	if err != nil {
 		return nil, err
 	}
-	schemaDef := NewSchemaDefinition(avroCodec)
-	resolvedSchema, err := json.Marshal(schemaDef.Codec)
+	resolvedSchema, err := json.Marshal(avroCodec)
 	if err != nil {
 		return nil, err
 	}
@@ -191,7 +180,6 @@ func (js *JSONSchema) GetSchemaInfo() *SchemaInfo {
 }
 
 type ProtoSchema struct {
-	AvroCodec
 	SchemaInfo
 }
 
@@ -214,12 +202,10 @@ func NewProtoSchemaWithValidation(protoAvroSchemaDef string, properties map[stri
 	if err != nil {
 		return nil, err
 	}
-	schemaDef := NewSchemaDefinition(avroCodec)
-	resolvedSchema, err := json.Marshal(schemaDef.Codec)
+	resolvedSchema, err := json.Marshal(avroCodec)
 	if err != nil {
 		return nil, err
 	}
-	ps.AvroCodec.Codec = schemaDef.Codec
 	ps.SchemaInfo.Schema = string(resolvedSchema)
 	ps.SchemaInfo.Type = PROTOBUF
 	ps.SchemaInfo.Properties = properties
@@ -322,7 +308,7 @@ func (ps *ProtoNativeSchema) GetSchemaInfo() *SchemaInfo {
 }
 
 type AvroSchema struct {
-	AvroCodec
+	Codec avro.Schema
 	SchemaInfo
 }
 
@@ -343,9 +329,8 @@ func NewAvroSchemaWithValidation(avroSchemaDef string, properties map[string]str
 	if err != nil {
 		return nil, err
 	}
-	schemaDef := NewSchemaDefinition(avroCodec)
-	as.AvroCodec.Codec = schemaDef.Codec
-	resolvedSchema, err := json.Marshal(schemaDef.Codec)
+	as.Codec = avroCodec
+	resolvedSchema, err := json.Marshal(avroCodec)
 	if err != nil {
 		return nil, err
 	}