We will create a writer in this track to offload data from a Kafka topic to a persistent medium. The write target will be a table in Google Bigquery.
The write target is a Google Bigquery table with the following schema.
The “payments” table is located in the “finance” dataset. But you can name the dataset and table with whatever you like, as long as the fields are the same as defined above.