tests(ticdc): fix the flaky test (#9191)

ref #2246
pingcap · Jun 12, 2023 · a912663 · a912663
1 parent 258acb3
commit a912663
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/tests/integration_tests/kafka_compression/run.sh b/tests/integration_tests/kafka_compression/run.sh
@@ -18,6 +18,9 @@ function test_compression() {
 	run_kafka_consumer $WORK_DIR "kafka://127.0.0.1:9092/$TOPIC_NAME?protocol=canal-json&version=${KAFKA_VERSION}&enable-tidb-extension=true"
 	run_sql_file $CUR/data/$1_data.sql ${UP_TIDB_HOST} ${UP_TIDB_PORT}
 
+	# sleep 10 seconds to wait for the data being sent to kafka.
+	sleep 10
+
 	compression_algorithm=$(grep "Kafka producer uses $1 compression algorithm" "$WORK_DIR/cdc.log")
 	if [[ "$compression_algorithm" -ne 1 ]]; then
 		echo "can't found producer compression algorithm"