Anil Dasari created FLINK-36587:
-----------------------------------
Summary: Postgres-cdc: Add support to override connector.class
Key: FLINK-36587
URL: https://issues.apache.org/jira/browse/FLINK-36587
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Affects Versions: 3.0.0
Reporter: Anil Dasari
Debezium offers various interfaces, such as struct makers, connector tasks, and
connectors, which allow you to override default behaviors and add extra
functionality.
Currently, the PostgreSQL CDC implementation uses the default
{{PostgresConnector}} class. This limitation makes it challenging to utilize
the different subclasses of {{PostgresConnector}} i.e our own sub class of{{
PostgresConnector}} with Flink PostgreSQL CDC.
Please consider adding support for overriding the {{"connector.class"}}
property (from Debezium configuration ?).
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
