kafka-jdbc-connector
kafka-jdbc-connector copied to clipboard
Simple way to copy data from relational databases into kafka.
Currently Kafka JDBC connector supports Kafka version 0.9.0.0. Add support for Kafka 0.9.0.1.
Ref #4 - Added support for PostgreSQL database
Add named based parameters to PostgreSQL prepare statement. ex: instead `SELECT * from sp_cdc_incrementing (?, ?)` we can use something like select * from `sp_cdc_incrementing(_id := ?, _batch := ?)`...
Since there is only one database connection created per connector, it stops working when connection is closed.