[
https://issues.apache.org/jira/browse/FLINK-36587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anil Dasari updated FLINK-36587:
--------------------------------
Description:
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.
https://github.com/apache/flink-cdc/blob/master/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/config/PostgresSourceConfigFactory.java#L60
Please consider adding support for overriding the {{"connector.class"}}
property (from Debezium configuration ?).
was:
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 ?).
> 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
> Priority: Major
>
> 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.
> https://github.com/apache/flink-cdc/blob/master/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/config/PostgresSourceConfigFactory.java#L60
> Please consider adding support for overriding the {{"connector.class"}}
> property (from Debezium configuration ?).
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
