Plain Json to JDBC Sink

Hello ,

I am doing a Kafka Setup in which I am getting the nested plain json data in a topic from an API response. I want to put this data in Redshift. I am using JDBC sink connector to sink the data in Redshift . But I am not able to sink the data in Redshift table.

Could you please help me in this , Below are the sample data -

{"vechicle_id": 1234, "vechicle_type": "bike","track_data":[{"location_city, :"xyz","timestamp": "2022-02-19 09:37:38"}]}

I am getting below error :-
null (INT32) type doesn't have a mapping to the SQL database column type

Let me know what is the proper connector config to use this schema and sink to database.

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.