kafka-connect-jdbc-sink icon indicating copy to clipboard operation
kafka-connect-jdbc-sink copied to clipboard

This repository contains a Kafka Connect sink connector for copying data from Apache Kafka into databases using JDBC.

Results 15 kafka-connect-jdbc-sink issues
Sort by recently updated
recently updated
newest added

# Description Fixes # (issue) This will allow the sink operator when used with Db2 to be able to use the MEMORY_TABLE function to batch rows in a blob and...

Bumps [org.postgresql:postgresql](https://github.com/pgjdbc/pgjdbc) from 42.6.0 to 42.7.2. Release notes Sourced from org.postgresql:postgresql's releases. v42.7.1 Fixed regressions since 42.7.0 Revert "Use canonical DateStyle name (#2925)" @​vlsi (#3035) Revert "feat: support SET statements...

dependencies

### What happened? It appears that the connector only works if the target table in Db2 isn't already defined. When attempting to write to an existing Db2 table, it fails...

bug

The JDBC sink does not make an attempt to log into the target database via JDBC until after it receives data from the intended topic(s). I suggest an initial connection...

enhancement

When connecting to a Kafka topic, the JDBC sink expects well-formatted JSON data or immediately fails. I propose that rather than fail without grace, it should either ignore or at...

Observation --- - There are TODOs that can be removed / covered by existing Issues. - There is a lack of docs on the classes and methods to explain what...

documentation
good first issue

Obervation --- Version 1.0 initial commit had no tests accompanied with it. Add dependencies: ``` org.junit.jupiter junit-jupiter-engine 5.6.2 test org.mockito mockito-core 3.3.3 test ``` Action Item --- Add tests at...

enhancement
good first issue

Observation --- Sometimes mistakes are made when transactions are sent - especially depending on the isolation levels #25. As a result, RDBMS implement save points and rollback behavior. Action Item...

enhancement

Observation --- Relational DBMS use transaction to preserve data integrity. To avoid conflicts during a transaction, the db locks, mechanisms for blocking access by others to the data that is...

enhancement