Thanks for quick response.
I read through the online doc on filter and all I could see at the end was a reference to formatted_record which I tried even though i thought that was not really what you meant. and, not surprsingly, it did not work. I am still not clear on how to make a field that is basically the original raw json log. Appreciate your help.
Here is my conf:
<filter kafka.consumer.mytopic>
@type record_transformer
<record>
raw_log formatted_record
</record>
</filter>
<match kafka.consumer.mytopic>
@type bigquery
auth_method json_key
json_key /fluentd/etc/LL-POC-9081311ba6a0.json
project ll-poc
dataset SL_POC
table sansar_logs_v1
auto_create_table true
field_string raw_log
buffer_queue_limit 10240
num_threads 16
buffer_type file
buffer_path /var/log/buffer/bq
</match>