# Exception in JDBC sink connector

**URL:** https://community.cratedb.com/t/exception-in-jdbc-sink-connector/1826
**Category:** CrateDB
**Created:** [August 1, 2024, 10:29am UTC](https://community.cratedb.com/t/exception-in-jdbc-sink-connector/1826 "2024-08-01T10:29:57Z")
**Posts on this page:** 1
**Showing post:** 6

<div class="post-metadata">

### Author: ![gorde.akshay](https://avatars.discourse-cdn.com/v4/letter/g/c4cdca/32.png) [@gorde.akshay](https://community.cratedb.com/u/gorde.akshay)
#### Post date: [August 2, 2024, 12:25pm UTC](https://community.cratedb.com/t/exception-in-jdbc-sink-connector/1826/6 "2024-08-02T12:25:33Z")

</div>

Hi matriv

After adding postgresql-42.7.3.jar it throws the below exception

Caused by: org.apache.kafka.connect.errors.ConnectException: Sink connector ‘cratedb-connector’ is configured with ‘delete.enabled=false’ and ‘pk.mode=kafka’ and therefore requires records with a non-null Struct value and non-null Struct schema, but found record at (topic=‘Mytopic’,partition=0,offset=20,timestamp=1722577031564) with a HashMap value and null value schema.

---

_[View the full topic](https://community.cratedb.com/t/exception-in-jdbc-sink-connector/1826)._