kafka-connect-jdbc

kafka-connect-jdbc copied to clipboard

Topic, message and key from columns

2

## Problem We wanted to use this JDBC Connector not to produce messages that expose our database schema but clean JSON messages that have been prepared in a database table...

walec51

Support Postgres partitioned table #1092

7

## Problem Postgres partitioned tables are not supported [after this change in the driver](https://github.com/pgjdbc/pgjdbc/commit/25eb32c8681eaa4aaac801808b6028e9f5dfbea8#diff-0571f8ac3385a7f7bb34e5c77f8afd24810311506989379c2e85c6c16eea6ce4L1287). #1092 ## Solution Map `PARTITIONED TABLE` as a valid value; not yet enabled by default, although...

timtebeek

Kafka Connector stops if connection with database breaks with Source Connector

4

Scenario: Kafka-connect with JDBC Source connector talking to SQLServer is up and running and polling a database table. The SQLServer is taken down. The Kafka-connect log file shows: [2019-12-12 09:58:14,124]...

y24jds

Need info for below use case: Use case 1: 1 source connector task.max = 2 table.whitelist=table1 For this property how many JDBC connection will get created. Use case 2: 1...

vigneshtvp

Use racially neutral terms in codebase

1

## Problem Some configurations and many variables throughout the code base use racially charged terms. ## Solution - Introduce new configurations. Existing configurations using racially charged terms are marked as...

mimaison

Error - Get current timestamp on firebird

4

Hi I need to set up kafka-connect with timestamp increment with Firebird. However I got an error: DEBUG TimestampIncrementingTableQuerier{table="CATEGORIES", query='null', topicPrefix='FB_', incrementingColumn='', timestampColumns=[LAST_MODIFIED]} prepared SQL query: SELECT * FROM "CATEGORIES"...

sylwekdec

informix source with timestamp column doesn't work

7

Using timestamp mode with an Informix database doesn't work source configuration: ```json name: my_connector config: 'connector.class': io.confluent.connect.jdbc.JdbcSourceConnector 'tasks.max': 1 'key.converter': org.apache.kafka.connect.json.JsonConverter 'value.converter': org.apache.kafka.connect.json.JsonConverter 'connection.url': '...' 'mode': timestamp 'timestamp.column.name': create_stamp 'topic.prefix':...

dboyce

JDBC Source Connector connection.url error

8

Hi I have installed the confluent local version - 7.1.1. After installing the kafka-connect-jdbc getting this error `An unexpected error occurred: org.apache.kafka.common.config.ConfigException: Missing required configuration "connection.url" which has no default...

dipdeb

Add Redshift dialect implementation

3

## Problem The current implementation of kafka-connect-jdbc does not properly support Redshift. Adding multiple columns does not work. Redshift converts the TEXT type to VARCHAR(256) by default. For many data,...

jirufik

RCCA-7749: Pick binding method according to column def for SqlServer

1

## Problem ## Solution ##### Does this solution apply anywhere else? - [ ] yes - [ ] no ##### If yes, where? ## Test Strategy ##### Testing done: -...

rajdangwal