sink(ticdc): add compression for avro test (#6974)

ref #5928
pingcap · Sep 6, 2022 · 6f9c00d · 6f9c00d
1 parent eeea2d0
commit 6f9c00d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/tests/mq_protocol_tests/framework/avro/kafka_docker_env_test.go b/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-bigint-unsigned-handling-mode=string",
+			"&avro-bigint-unsigned-handling-mode=string&compression=gzip",
 		SchemaRegistry: "http://schema-registry:8081",
 	}
 }

diff --git a/tests/mq_protocol_tests/framework/avro/kafka_single_table.go b/tests/mq_protocol_tests/framework/avro/kafka_single_table.go
@@ -43,7 +43,7 @@ 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-bigint-unsigned-handling-mode=string",
+			"?kafka-version=2.6.0&protocol=avro&avro-bigint-unsigned-handling-mode=string&compression=gzip",
 		SchemaRegistry: "http://schema-registry:8081",
 	}
 }