jcustenborder / kafka-connect-json-schema

Apache License 2.0
14 stars 14 forks source link

How can I use this with sink my raw JSON data using JDBC sink connector #15

Open ttrading opened 3 years ago

ttrading commented 3 years ago

I have some messages that I would like to transfer from Kafka to Psql. My messages are in raw json format and I have been looking for a solution because I know jdbc sink will not accept it without a schema. Can you please explain if I can use this project to take care of this issue. My sample data is as follows:

{ "type": "Point", "time": "2021-04-01T01:19:21.243866342Z", "value": 1, "metric": "iterations", "method": "", "name": "", "proto": "", "status": "", "tls_version": "", "url": "", "expected_response": "", "group": "", "scenario": "default", "agent_hostname": "ip-172-21-10-175.ap-southeast-2.compute.internal", "agent_ipaddress": "34.34.12.12", "agent_casetype": "simplerequest", "agent_casename": "test_case" }