kafka-connect-jdbc

kafka-connect-jdbc copied to clipboard

SqlServer nvarchar and Postgres varchar dialect specific pk constraint restrictions

5

## Problem SqlServerDialect Sink defaults strings as varchar(max) instead of nvarchar(n) of upstream system schema ## Solution Switch from varchar to nvarchar and project optional field length from connect.parameters of...

epheatt

I have a debezium source connector for postgres setup. I also have a debezium JDBC sink connector setup to sync data to another target postgres db. My source connector config...

sm0003-alt

After 2 years I' trying to update our kafka-connect to latest version. Most of plugins works without any problems on new version except JdbcSinkConnector. I'm getting following error: ``` No...

brekko1st

I'm trying to create a JDBC source connector to read an entry from the database and write it to the Kafka topic. The setup works fine with hardcoded username/password, but...

Shubham-Garg20

Exception Kafka connect Offset commit cannot be completed since the consumer is not part of an active group for auto partition assignment; it is likely that the consumer was kicked out of the group.

6

Source: Confluent Kafka Version: 5.5.1 PostgreSQL JDBC Sync Found this exception, during the DB restart. ERROR WorkerSinkTask{id=postgres-sink-data-value-events-0} Commit of offsets threw an unexpected exception for sequence number 13: {data-value-events-1=OffsetAndMetadata{offset=34292986, leaderEpoch=null,...

gopalakrishnan-subramani

Hi everyone, I would like to know if there is a Kakfa sink connector to a Vector Database different from Atlas Vector. Thanks in advance!

laurafbec

## Environment kafka:2.4 zookeeper:2.4 confluentinc-kafka-connect-jdbc-10.7.6 ## Test ### producer ``` bin/kafka-console-producer.sh --broker-list 172.17.0.229:9092 --topic ob7 --property "parse.key=true" --property "key.separator=:" ``` send simple message : `5:{"id":5}` ### watcher start a watcher...

sunzhaoyang

On the connector configuration we can configure the following: errors.deadletterqueue.topic.name errors.deadletterqueue.context.headers.enable errors.deadletterqueue.topic.replication.factor But we don't have any option for errors.deadletterqueue.topic.partitions It always forces the partition number for DLQs into 1...

leonardocaylent

PostGIS support using Debezium libaries

5

## Problem PostGIS data types were not supported by Kafka JDBC sink connector ## Solution Added support using the DBZ core library. Still the array of postgis datatypes needs to...

rgannu

Replacing \u0000 with nothing for PostgreSqlDatabaseDialect

7

## Problem \u0000 UFT character is not supported by Postgres text field. An attempt to insert fails with error: `org.postgresql.util.PSQLException:` ERROR: invalid byte sequence for encoding "UTF8": 0x00` ## Solution...

oleksandrkovalenko