Skip to content

Commit

Permalink
fix check
Browse files Browse the repository at this point in the history
Signed-off-by: Ping Yu <[email protected]>
  • Loading branch information
pingyu committed Jan 4, 2024
1 parent 4d33975 commit 6f4ed41
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions cdc/tests/integration_tests/_utils/run_kafka_consumer
Original file line number Diff line number Diff line change
Expand Up @@ -26,31 +26,31 @@ 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

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"

0 comments on commit 6f4ed41

Please sign in to comment.