From 6f4ed411ebcd309d21be6f2fae779b624d1aef12 Mon Sep 17 00:00:00 2001 From: Ping Yu Date: Thu, 4 Jan 2024 11:08:21 +0800 Subject: [PATCH] fix check Signed-off-by: Ping Yu --- .../_utils/run_kafka_consumer | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/cdc/tests/integration_tests/_utils/run_kafka_consumer b/cdc/tests/integration_tests/_utils/run_kafka_consumer index 77eb709d..acd582e4 100755 --- a/cdc/tests/integration_tests/_utils/run_kafka_consumer +++ b/cdc/tests/integration_tests/_utils/run_kafka_consumer @@ -26,21 +26,21 @@ while [[ $# -gt 0 ]]; do --upstream-uri) upstream_uri=$2 shift - shift + shift ;; --downstream-uri) downstream_uri=$2 shift - shift + shift ;; --log-suffix) log_suffix=$2 shift - shift + shift ;; *) echo "run_kafka_consumer: Unknown argument: $key" - exit 1 + exit 1 ;; esac done @@ -48,9 +48,9 @@ done echo "[$(date)] <<<<<< START kafka consumer in $TEST_NAME case >>>>>>" cd "$workdir" cdc_kafka_consumer \ - --log-file "$workdir/cdc_kafka_consumer$log_suffix.log" \ - --log-level info \ - --upstream-uri "$upstream_uri" \ - --downstream-uri "$downstream_uri" \ - >> "$workdir/cdc_kafka_consumer_stdout$log_suffix.log" 2>&1 & + --log-file "$workdir/cdc_kafka_consumer$log_suffix.log" \ + --log-level info \ + --upstream-uri "$upstream_uri" \ + --downstream-uri "$downstream_uri" \ + >>"$workdir/cdc_kafka_consumer_stdout$log_suffix.log" 2>&1 & cd "$pwd"