Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Support for PostgreSQL #4

Open
arpanchaudhury opened this issue Jul 8, 2017 · 3 comments
Open

Support for PostgreSQL #4

arpanchaudhury opened this issue Jul 8, 2017 · 3 comments

Comments

@arpanchaudhury
Copy link
Member

arpanchaudhury commented Jul 8, 2017

Add support to copy change data from PostgreSQL

@atiqsayyed
Copy link

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

@arpanchaudhury
Copy link
Member Author

arpanchaudhury commented Jul 8, 2017

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

@atiqsayyed
Copy link

I've started working on it

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

2 participants