[Bug] Debezium connetor does not create heartbeat topic

[yurymuski]

Search before asking

• I searched in the issues and found nothing similar.

Version

Ubuntu 20.04

Pulsar 2.10.4

Minimal reproduce step

Setting up Debezium source via example doc
https://pulsar.apache.org/docs/2.10.x/io-cdc-debezium/#example-of-postgresql

add to debezium-postgres-source-config.yaml heartbeat configs

    heartbeat.interval.ms: 1000
    heartbeat.topics.prefix: debezium-heartbeat
    heartbeat.action.query: "SELECT pg_logical_emit_message(false, 'heartbeat', now()::varchar);"

heartbeat.action.query may be any insert for example

What did you expect to see?

heartbeat crates topic, updates DB, sends events to it

What did you see instead?

no topic, no DB updates

Anything else?

No response

Are you willing to submit a PR?

• I'm willing to submit a PR!

[github-actions]

The issue had no activity for 30 days, mark with Stale label.

[MissakaI-Cloudtrix]

AFAIK the Pulsar's Debezium connector doesn't have all the features in Debezium itself.

All configuration properties found in https://debezium.io/documentation/reference/3.0/connectors/postgresql.html#postgresql-connector-properties

Not available in https://pulsar.apache.org/docs/4.0.x/io-cdc-debezium/#configuration

Not available even in latest Pulsar implementation.

Would like to have this feature implemented. As I am maxing out my db slots as the table I monitor doesn't have high traffic. Therefore the pg_replication_slot size increases to max.