On the sideline I also validated the Json format
{"schema": { "type": "struct", "fields": [ { "field": "rowkey", "type":
"string", "optional": true}],"optional": false,"name": "BQ"}, "payload":
{"rowkey": "c0224abd-a6c4-4743-ac01-55e7b6980062"}}
[image: image.png]
Thanks
LinkedIn *
https://ww
This is what is termed as fun and game.
Trying to write a single column (for the sake of test) in this case to
BigQuery from Kafka. I am sending the schema and payload as per docs
This is message sent that I can get it from console
$KAFKA_HOME/bin/kafka-console-consumer.sh --bootstrap-server
rhe
