kafka-connect-jdbc

kafka-connect-jdbc copied to clipboard

Implicit Conversion error from topic to Microsoft SQL

4

Hi Getting this error when trying to sink topic data to Microsoft SQL - any ideas of things to try to get around this please? io.confluent.connect.jdbc.sink.JdbcSinkTask put - Write of...

mikementzmaersk

JDBC Sink to Postgres cannot ignore duplicates

15

The JDBC Sink has three [insert modes](https://docs.confluent.io/current/connect/connect-jdbc/docs/sink_config_options.html#writes): `insert`, `upsert`, and `update`. In Postgres, using `upsert` produces an insert of the form [`INSERT ... ON CONFLICT (...) DO UPDATE SET ...`](https://github.com/confluentinc/kafka-connect-jdbc/blob/master/src/main/java/io/confluent/connect/jdbc/sink/dialect/PostgreSqlDialect.java#L78)`,...

slepkin

- cp-kafka-connect:7.0.1 - cp-kafka-rest:7.0.1 - cp-schema-registry:7.0.1 - cp-server:7.0.1 - cp-zookeeper:7.0.1 - kafka-connect-jdbc:10.2.6 --- Folks, I'm going nuts here. For some reason the jdbc sink is treating the avro branch as...

neilor-mendes

Support for connection pool with HikariCP

1

## Problem Connection with some DB solutions like aurora serverless were not able to be closed when not used. In this specific case, Aurora wasn't able to scale down to...

irux

Add a new Mode "incrementing+delay_timestamp" in JDBC Source Connector

6

We always lose some data when using "incrementing" mode on large table! **PROBLEM DESCRIPTION** If there are a lot of parallel insert operations going on in the source table (which...

ussama-rafique

## Context * Kafka Connect 6.1.2 * JDBC connector 10.2.1 ## Current behaviour We have stumbled upon an issue on a running cluster with multiple source connectors: * One of...

colinsmetz

Timestamp mode not working and table.whitelist does not allow to poll data from multiple tables for jdbc Kafka connector.

2

Hi All I am still facing issue with the mode timestamp in jdbc kafka source connector. All of the above recommendations have been implemented by me. I have converted the...

nik09541

1088: Add connection ttl config

4

## Problem Original issue: https://github.com/confluentinc/kafka-connect-jdbc/issues/1088 The current implementation of the source and sink connectors maintains a single database connection indefinitely across all connectors and tasks, only cycling if the connection...

Bradleywboggs

Foreign Keys not handled

2

How can I handle foreign key constraints at the sink jdbc connector. Should I just set mode to upsert and it will ignore all messages violating constraints and whenever foreign...

adityagupta1089

the underhood query issued to get the current time stamp is not supported in AS400. it only support CURRENT TIMESTAMP without paramenter.  my jdbc source configuration "mode": "timestamp+incrementing",...

axeman74