All Questions
6 questions
0
votes
1
answer
60
views
How to reset Debezium offset to start streaming from different DB server after migration
We are using Debezium connectors to stream PostgreSQL data into kafka. We will have a major version upgrade on PostgreSQL(13 to 16) by side by side approach using logical replication to new server. ...
- 194
0
votes
1
answer
629
views
Embedded Debezium WAL piling up restart_lsn not moving
So we are using debezium in our spring boot application. And while the messages are getting consumed, the restart_lsn is not moving and the replication slot lag is increasing.
postgres=# SELECT
...
- 59
0
votes
1
answer
4k
views
Debezium for Postgress and WAL flush
I have Debezium in a container, capturing all changes of PostgeSQL database records. But i am unable to understand couple of things regarding how Debezium works. If Debezium starts for the first time ...
- 1,452
0
votes
1
answer
2k
views
Debezium `source.lsn` field value in snapshot records(when `__op=r`)
I can't find an information in Debezium Postgresql connector config documentation page regarding the source.lsn field value for snapshot events(events having __op=r). I've ran a test on my dev ...
- 1,064
1
vote
2
answers
931
views
Make wal2json listen to tables without Primary Key
When I create a table with a Primary Key on PostgreSQL 10
create table test (t1 int, t2 varchar, primary key(id));
and stream data from PostgreSQL to Kafka through Debezium using wal2json with these ...
- 719
1
vote
1
answer
777
views
Conversion of numeric in wal2json
I have a column X, which has datatype numeric, in a table.
After streaming changes from PostgreSQL 10 to Kafka using debezium together with the logical decoding plugin, wal2json; I read the json ...
- 719