kafka-connect-jdbc

kafka-connect-jdbc copied to clipboard

Query with WHERE clause cannot be used with incrementing/timestamp mode

8

[docker-compose.yml for env setup is here](https://github.com/confluentinc/demo-scene/blob/connect-jdbc/connect-jdbc/docker-compose.yml) Normal `query`, no predicate: ``` curl -X POST http://localhost:8083/connectors -H "Content-Type: application/json" -d '{ "name": "jdbc_source_postgres_01", "config": { "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector", "connection.url": "jdbc:postgresql://postgres:5432/postgres", "connection.user": "connect_user",...

rmoff

support clickhouse

5

to support clickhouse! thanks!

cmdares

OutOfMemory with mariadb java driver

1

Hello, We are facing OOM with JDBC source connector with large table (80 millions of rows) We have found some existing issues - https://github.com/confluentinc/kafka-connect-jdbc/issues/34 - https://github.com/confluentinc/kafka-connect-jdbc/pull/775 Database : RDS Aurora...

cyriljoui

JDBC Kafka Connector Not Sending Messages in Timestamp mode, only in Bulk

14

Hi, I'm encountering an issue where for a specific query when deployed with a JDBC kafka connector in timestamp mode, it never sends any messages. That exact same connector, with...

aleks-myplanet

I am trying to push data to my clickhouse server from mysql using kafka connect connector. Both MySQL and Clickhouse are in "America/Los_Angeles" timezone. End user is inserting data to...

ghamandipp

Error ORA-01461 when BLOB writes to Oracle

1

This fix solves the CLOB problem, but the blob still reports the same error。  2020-10-19 10:06:09,099] INFO Setting metadata for table "ZPF_TEST_101301_DY" to Table{name='"ZPF_TEST_101301_DY"', type=TABLE columns=[Column{'id', isPrimaryKey=true, allowsNull=false, sqlType=NUMBER},...

xionglizhi

fix: db.timezone invalid timezone identifier error

4

## Problem connect crashes with ```invalid time zone identiferi``` exception thrown when ```db.timezone``` parameter is specified in sink properties ## Solution List of available timezones and given timezone comparision uses...

thebinary

Postgis support using Debezium

15

Hello everyone, I am using the **JDBC sink-connector** together with **Debezium**. At the moment I am facing the following issue. Our data contains **Postgis data types**, which are supported by...

daanroosen-DS

Support for clickhouse in confluent

3

I am trying JdbcSinkConnector to dump the data from kafka topic to clickhouse. following are the things done : 1. Downloaded clickhouse-jdbc-0.2.4-shaded.jar and put in the classpath of connnector. https://repo1.maven.org/maven2/ru/yandex/clickhouse/clickhouse-jdbc/0.2.4/clickhouse-jdbc-0.2.4-shaded.jar...

shivakumarss

WorkerSourceTask: Failed to flush, timed out while waiting for producer to flush outstanding 1 messages

1

I am running a Kafka connector for MirrorMakerCheckpoint connector on confluent 7.0.0. However the checkpoint connector WorkerTask fails. I have tried to set `offset.flush.timeout.ms = 100000` as mentioned in :...

rupeshmore85