Skip to content

Commit

Permalink
[BEAM-14050] Update taxi.go example instructions
Browse files Browse the repository at this point in the history
  • Loading branch information
jrmccluskey authored and nancyxu123 committed Mar 9, 2022
1 parent 83f05a9 commit a995627
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion sdks/go/examples/kafka/taxi.go
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,8 @@
// export JOB_NAME="kafka-taxi-`date +%Y%m%d-%H%M%S`"
// export BOOTSTRAP_SERVERS="123.45.67.89:1234"
// export EXPANSION_ADDR="localhost:1234"
// go run ./sdks/go/examples/kafka/taxi.go \
// cd ./sdks/go
// go run ./examples/kafka/taxi.go \
// --runner=DataflowRunner \
// --temp_location=$TEMP_LOCATION \
// --staging_location=$STAGING_LOCATION \
Expand Down

0 comments on commit a995627

Please sign in to comment.