Establish a Postgres CDC Connection

[grantcloud]

hey team - I'm trying to standup a CDC connection to PostGres. The docs here says PostGres CDC is supported - but the CDC guide doesn't show an example of establishing that connection to create a source.

Any help would be appreciated. Thanks

[liurenjie1024]

Hi, @grantcloud Currently we can't connect to postgre directly and consume its changelog. It requires customer to setup debezium to produce changes into some message such as kafka, and we can consume debezium format message in kafka.

[grantcloud]

Good to know - thanks for the helpful response.

[liurenjie1024]

We are also heavily working on connecting postgre to consume its cdc directly.

[neverchanje]

Hi @grantcloud Here is the document of Postgres CDC: https://www.risingwave.dev/docs/current/ingest-from-postgres-cdc/ We just released this feature in the 0.1.16 version.

[fuyufjh]

Direct PostgreSQL CDC Connector will be released in a few days. With this connector, RisingWave can connect to PostgreSQL directly to obtain data from the binlog without starting additional services. See Using the native PostgreSQL CDC connector for details.