# JDBC sink connector Schema

**URL:** <https://forum.confluent.io/t/jdbc-sink-connector-schema/8118>\
**Category:** Kafka Connect\
**Created:** [18 June 2023 11:04 UTC](https://forum.confluent.io/t/jdbc-sink-connector-schema/8118 "2023-06-18T11:04:19Z")\
**Posts on this page:** 3\
**Page:** 1

<div class="post-metadata">

**Author:** ![kang](https://avatars.discourse-cdn.com/v4/letter/k/d6d6ee/32.png) [@kang](https://forum.confluent.io/u/kang)\
**Post date:** [18 June 2023 11:04 UTC](https://forum.confluent.io/t/jdbc-sink-connector-schema/8118/1 "2023-06-18T11:04:19Z")

</div>

Hi There, I’m trying to insert my data from a Kafka Topic into clickhouse with theJDBC Sink Connector.  
This is my connector config

```auto
{
  "name": "JdbcSinkConnector",
  "config": {
    "value.converter.schemas.enable": "false",
    "name": "JdbcSinkConnector_auth_events",
    "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
    "key.converter": "org.apache.kafka.connect.json.JsonConverter",
    "value.converter": "org.apache.kafka.connect.json.JsonConverter",
    "errors.retry.timeout": "100",
    "errors.retry.delay.max.ms": "60000",
    "topics": "my_topic",
    "connection.url": "jdbc:clickhouse://clickhouse:8123/my_db",
    "connection.user": "default",
    "connection.password": "",
    "insert.mode": "insert",
    "batch.size": "1000",
    "table.name.format": "my_tb",
    "pk.mode": "record_value",
    "auto.create": "true",
    "auto.evolve": "true"
  }
}

```

and this is my message

```auto
{
  "ts": 1682006722000,
  "sessionId": 194860,
  "auth": "Logged In",
  "level": "free",
  "itemInSession": 5,
  "city": "Erie",
}

```

but got an error `Error: Sink connector 'JdbcSinkConnector_my_topic' is configured with 'delete.enabled=false' and 'pk.mode=record_value' and therefore requires records with a non-null Struct value and non-null Struct schema, but found record at (topic='my_topic',partition=0,offset=0,timestamp=1687020175058) with a HashMap value and null value schema. (org.apache.kafka.connect.runtime.WorkerSinkTask)`  
Pls help me, thanks all

---

<div class="post-metadata">

**Author:** ![OneCricketeer](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/onecricketeer/32/1551_2.png) [@OneCricketeer](https://forum.confluent.io/u/OneCricketeer)\
**Post date:** [23 June 2023 03:30 UTC](https://forum.confluent.io/t/jdbc-sink-connector-schema/8118/2 "2023-06-23T03:30:40Z")

</div>

What’s unclear about the error? Plain JSON has no schema. Are you able to modify your producer to send a schema with the JSON, or even better, use a different format like Avro or Protobuf which does have a schema?

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/flex019/uploads/confluentcommunity/original/1X/c49438c90c9df282e9996fdf6971be890c71b65a.svg) [@system](https://forum.confluent.io/u/system)\
**Post date:** [23 July 2023 03:31 UTC](https://forum.confluent.io/t/jdbc-sink-connector-schema/8118/3 "2023-07-23T03:31:34Z")

</div>

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