kafka-connect-jdbc

kafka-connect-jdbc copied to clipboard

Converting byte[] to Kafka Connect data failed due to serialization error of topic connect-topic1:

2

Even though I'm passing the right schema registry and the converter class I'm still getting this error ``` 2022-04-11 11:47:20,038 ERROR WorkerSinkTask{id=databus-sink-connector1-0} Error converting message value in topic 'connect-topic1' partition...

Utkarsh-0211

Dead letter queue topic not getting created as KAFKA Admin client times out for listTopics method

1

I am trying to enable dead letter on my JDBC Sink Connector. In sink connector configuration, I have provided following properties ``` 'errors.tolerance'='all', 'errors.deadletterqueue.topic.name' = 'error_topic', 'errors.deadletterqueue.topic.replication.factor'= -1 ``` But...

raipragyaa

Reduce retention.ms from default 7 days to 1 day (Make it configurable) for the dead letter topic created for error handling via sink connector

2

Hi, We are creating a sink connector along with the error handling mechanism , so if in case if there is bad record it is routed to error queue ,...

souvikdgreat

It is impossible to stop the source connector before it has exhausted all its connection attempts. If you configured wrong DB connections params or your DB is unreachable, you can...

fred-ro

Hi All, version: Kafka-Connect-jdbc:10.4.1 My issue is exactly same as what was described in below case . I am getting error while inserting null value to column of type binary...

sgv0007

SQL Server - Implicit conversion from data type nvarchar to varbinary is not allowed

2

Error happens when sink connector attempts to insert record with binary data type (varbinary) that is null value. I have Inspected with SQL profiler nvarchar(4000) data type is built instead...

alexpee

Hello, I use Kafka connect JDBC sink to write data to Oracle. Once the BLOB field type is added, it becomes very slow. For example, I define the writing batch...

ryan-0526

Map Oracle type NUMBER(19,0) to long

7

I have several Oracle tables with fields defined as NUMBER(19,0). I configured numeric.precision.mapping=true and was expecting long but I'm getting bytes. On [DataConverter.java#L208](https://github.com/confluentinc/kafka-connect-jdbc/blob/master/src/main/java/io/confluent/connect/jdbc/source/DataConverter.java#L208) and [DataConverter.java#L399](https://github.com/confluentinc/kafka-connect-jdbc/blob/master/src/main/java/io/confluent/connect/jdbc/source/DataConverter.java#L399) there is a check for...

marcushalonen

Hello All, I am new to Kafka and exploring Debezium for Change Data Capture. I have used Debezium source connector to read data from Oracle database. In the Kafka Topic,...

rajp2007

kafka-connect-jdbc source - stop query against ALL_OBJECTS

2

Hi, Based on **table.poll.interval.ms** parameter definition the following query constantly running from each Kafka JDBC connector. We configured our jdbc kafka connector jobs with query mode so we don't want...

cuneytykaya