kafka-connect-jdbc-sink
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.
# 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...
### 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...
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...
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...
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...
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...
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...