codec(ticdc): update goavro to 2.11.1 to solve avro decimal encoding …

…bug (#5556)

close #5554

go.mod

@@ -43,7 +43,7 @@ require (
 	github.com/jarcoal/httpmock v1.0.8
 	github.com/jmoiron/sqlx v1.3.3
 	github.com/kami-zh/go-capturer v0.0.0-20171211120116-e492ea43421d
-	github.com/linkedin/goavro/v2 v2.9.8
+	github.com/linkedin/goavro/v2 v2.11.1
 	github.com/mattn/go-shellwords v1.0.12
 	github.com/modern-go/reflect2 v1.0.2
 	github.com/phayes/freeport v0.0.0-20180830031419-95f893ade6f2

go.sum

@@ -796,8 +796,9 @@ github.com/lib/pq v1.1.1/go.mod h1:5WUZQaWbwv1U+lTReE5YruASi9Al49XbQIvNi/34Woo=
 github.com/lib/pq v1.2.0/go.mod h1:5WUZQaWbwv1U+lTReE5YruASi9Al49XbQIvNi/34Woo=
 github.com/lib/pq v1.10.3 h1:v9QZf2Sn6AmjXtQeFpdoq/eaNtYP6IN+7lcrygsIAtg=
 github.com/lib/pq v1.10.3/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
-github.com/linkedin/goavro/v2 v2.9.8 h1:jN50elxBsGBDGVDEKqUlDuU1cFwJ11K/yrJCBMe/7Wg=
 github.com/linkedin/goavro/v2 v2.9.8/go.mod h1:UgQUb2N/pmueQYH9bfqFioWxzYCZXSfF8Jw03O5sjqA=
+github.com/linkedin/goavro/v2 v2.11.1 h1:4cuAtbDfqkKnBXp9E+tRkIJGa6W6iAjwonwt8O1f4U0=
+github.com/linkedin/goavro/v2 v2.11.1/go.mod h1:UgQUb2N/pmueQYH9bfqFioWxzYCZXSfF8Jw03O5sjqA=
 github.com/lucasb-eyer/go-colorful v1.0.2/go.mod h1:0MS4r+7BZKSJ5mw4/S5MPN+qHFF1fYclkSPilDOKW0s=
 github.com/lucasb-eyer/go-colorful v1.0.3/go.mod h1:R4dSotOR9KMtayYi1e77YzuveK+i7ruzyGqttikkLy0=
 github.com/lufia/plan9stats v0.0.0-20211012122336-39d0f177ccd0 h1:6E+4a0GO5zZEnZ81pIr0yLvtUWk2if982qA3F3QD6H4=

tests/mq_protocol_tests/framework/avro/kafka_docker_env_test.go

@@ -54,7 +54,7 @@ func (t *dummyTask) GetCDCProfile() *framework.CDCProfile {
 	return &framework.CDCProfile{
 		PDUri: framework.UpstreamPD,
 		SinkURI: "kafka://kafka:9092/testdb_test?protocol=avro" +
-			"&avro-decimal-handling-mode=string&avro-bigint-unsigned-handling-mode=string",
+			"&avro-bigint-unsigned-handling-mode=string",
 		SchemaRegistry: "http://schema-registry:8081",
 	}
 }

tests/mq_protocol_tests/framework/avro/kafka_single_table.go

@@ -42,8 +42,8 @@ func (a *SingleTableTask) Name() string {
 func (a *SingleTableTask) GetCDCProfile() *framework.CDCProfile {
 	return &framework.CDCProfile{
 		PDUri: framework.UpstreamPD,
-		SinkURI: "kafka://kafka:9092/testdb_" + a.TableName + "?kafka-version=2.6.0" +
-			"&protocol=avro&avro-decimal-handling-mode=string&avro-bigint-unsigned-handling-mode=string",
+		SinkURI: "kafka://kafka:9092/testdb_" + a.TableName +
+			"?kafka-version=2.6.0&protocol=avro&avro-bigint-unsigned-handling-mode=string",
 		SchemaRegistry: "http://schema-registry:8081",
 	}
 }