apache / apache/pulsar

[Bug] Debezium connetor does not create heartbeat topic

Open
#20,594 2 comments 1 reaction 0 assignees View on GitHub
Stale type/bug
Dominant language
Java
Stars
15.3k
Forks
3.8k
Avg merge
1d 14h
Merged PRs (30d)
160

Description

### Search before asking

- [X] I searched in the [issues](https://github.com/apache/pulsar/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

```sh
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!

Contributor guide

Open the contributing guide

Research direction

Start by running the PostgreSQL Debezium source example from the 2.10.x CDC documentation with the settings in debezium-postgres-source-config.yaml. Check whether the heartbeat topic is created, the database is updated, and heartbeat events are sent; compare the observed behavior with the expected heartbeat configuration.

Written by the indexing model from the issue text.

Assessment

Tech stack
postgresql
Domain
databases, stream-processing
Issue type
Bug
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Mostly clear
Newbie friendliness
35/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.