Hello , I tried connect cratedb with kafka to get db pushed from MongoDB . This is my file json ubuntu@ip-172-31-19-57:~$ cat kafka-crate-sink-1.json { "name": "crate-sink-113", "config": { "connector.class": "io.debezium.connector.jdbc.JdbcSinkConnector", "tasks.max": "1", "topics…

Hi Mỹ Duyên, thanks for writing in. I’ve asked a colleague about the problem you might be observing, and he had a quick suggestion: My suspicion is they are sending records with an empty record body, i.e. the topic in Kafka has an empty JSON body? Maybe this can help you already? Otherwise, we …

[image] M_Duyen_L_u: "connection.url": "jdbc:postgresql://host:5432/CloudStore?stringtype=unspecified&tcpKeepAlive=true" I see that you are connecting using the vanilla pgJDBC driver, right? I am not sure about if this one would work, but the CrateDB JDBC Driver could possibly come to the res…

Hello amoth , I check data in topic after I use debezium to send data , I ensure that data same my before comment . It’s error because crateDB can’t understand format from data . Can you suggest me a config file of crateDB sink ? { "schema": { "type": "struct", "fields": [ …

I seen video demo kafka , debezium with mssql and cratedb , I took your team use postgresql jdbc so I use it but it’s not work

update: I use CrateDB JDBC , but I don’t know how to transform data to CrateDB . This is my file json : curl -X POST https://kafka-dev.khacthienit.click/connectors \ -H "Content-Type: application/json" \ -d '{ "name": "cratedb-sink-geo-oid-9", "config": { "connector.class": "io.confluent.co…

Hi again, thanks for trying to make it work. Apologies that our Java experts are currently on vacation, but please don’t fret – we’ll see what we can do for you. [image] M_Duyen_L_u: I tried connect cratedb with kafka to get db pushed from MongoDB [image] M_Duyen_L_u: where consumed rec…

but it’s error Still, also back to analyzing your error report. [image] M_Duyen_L_u: 2025-08-14 05:54:16,357 ERROR || Failed to process record: Failed to process a sink record [io.debezium.connector.jdbc.JdbcSinkConnectorTask] org.apache.kafka.connect.errors.ConnectException: Failed to p…

[image] M_Duyen_L_u: Can you suggest me a [working] config file of CrateDB sink ? That’s a good idea. Let us check our resources if we can find one. It’s an excellent opportunity to improve our documentation if it’s not easy to discover. Please also understand that people are regularly strug…

[image] amotl: [image] M_Duyen_L_u: 2025-08-14 05:54:13,284 ERROR || ERROR: Unrecognised Setting: TIMEZONE ^^ But wait, what is that? I can see others might be struggling with similar details around timezones as well. Problem with TimestampConverter from Confluent - Managed Connect…

Kafka sink connector failed

CrateDB Configuration

M_Duyen_L_u August 15, 2025, 1:16pm 12

hiii , this solution only copy db , I want to update real-time db from mongo to crate ^^

Exploring options to sync collections from MongoDB

Topic		Replies	Views
Kafka connect failed sink data to cratedb while the data doesn't exist in record CrateDB integration , sql	5	72	August 4, 2025
Exception related to pk.mode and delete.enabled CrateDB	1	213	August 6, 2024
Kafka connect sink Integrations	1	1068	July 14, 2020
Schema evolution via Confluent JDBC sink is failing due to wrong ALTER request CrateDB	3	2874	May 12, 2021
Kafka connect don't sink data to cratedb after adding more than 100 topics CrateDB integration	3	65	March 25, 2025

Kafka sink connector failed

Related topics