kafka-jdbc-connector icon indicating copy to clipboard operation
kafka-jdbc-connector copied to clipboard

Published 20 hours ago • verified publisher icon agoda-com

Support for PostgreSQL

Open arpanchaudhury opened this issue 8 years ago • 3 comments

Add support to copy change data from PostgreSQL

arpanchaudhury avatar Jul 08 '17 04:07 arpanchaudhury

I can pick this issue, do we wanna discuss how should we approach this?

atiqsayyed avatar Jul 08 '17 06:07 atiqsayyed

Thanks @atiqsayyed. There are 2 things that need to be done here.

  1. Updating kafka-jdbc-connector a. Add one more entry for PostgreSQL in DatabaseProduct.scala. b. Add prepareStatement to poll data from PostgreSQL in IdBasedDataService.scala, TimeBasedDataService.scala and TimeIdBasedDataService.scala.

  2. Updating sample a. add docker functional test KafkaConnectPostgresqlFunctionalTest.scala

arpanchaudhury avatar Jul 08 '17 07:07 arpanchaudhury

I've started working on it

atiqsayyed avatar Jul 10 '17 07:07 atiqsayyed