6508e5e7ad2e573449c11b3097800b1e42203984 - pulsar-connectors

commit	6508e5e7ad2e573449c11b3097800b1e42203984	[log] [tgz]
author	Jia Zhai <zhaijia@apache.org>	Sat Mar 30 05:39:20 2019 +0800
committer	Sijie Guo <guosijie@gmail.com>	Fri Mar 29 14:39:20 2019 -0700
tree	75dca091810f2d52baadf8a17028ba791293a059
parent	0b5c6d2b4522e5d23dc090bfa5473a95cd4565a2 [diff]

[Pulsar IO]: Add a source connector for debezium postgres (#3924)

This PR try to add a source connector for debezium postgres.

changes:
- add debezium postges project;
- add DebeziumSource, and make mysql and postgres both inherit from it.

pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/DebeziumSource.java[Added - diff]
pulsar-io/debezium/mysql/src/main/java/org/apache/pulsar/io/debezium/mysql/DebeziumMysqlSource.java[diff]
pulsar-io/debezium/pom.xml[diff]
pulsar-io/debezium/postgres/pom.xml[Added - diff]
pulsar-io/debezium/postgres/src/main/java/org/apache/pulsar/io/debezium/postgres/DebeziumPostgresSource.java[Added - diff]
pulsar-io/debezium/postgres/src/main/resources/META-INF/services/pulsar-io.yaml[Added - diff]
pulsar-io/debezium/postgres/src/main/resources/debezium-postgres-source-config.yaml[Added - diff]

7 files changed

tree: 75dca091810f2d52baadf8a17028ba791293a059

pulsar-io/