XML

Word

Printable

Details

Type: Bug
Resolution: Done
Priority: Major
Fix Version/s: 2.3.0.Beta1
Affects Version/s: 1.9.2.Final, 2.0.0.Alpha1
Component/s: debezium-server, postgresql-connector
Labels:
- bug

Blocked:
False
Blocked Reason:
None
Ready:
False
Git Pull Request:
https://github.com/debezium/debezium-server/pull/23
Steps to Reproduce:
1. Deploy Debezium Server using PostgreSQL and Google Cloud Pub/Sub configuration.
2. Wait a few hours

SFDC Cases Counter:
SFDC Cases Links:

Description

Bug report

What Debezium connector do you use and what version?

I deployed debezium/server docker image as a StatefulSet on Google Kubernetes Engine (GKE).

I tried Debezium Server 1.9.2.Final and 2.0.0.Alpha1 — both have this bug.

What is the connector configuration?

debezium.sink.type=pubsub
debezium.sink.pubsub.project.id=fastcup-224913
debezium.source.name=fastcup
debezium.source.slot.name=debezium_fastcup debezium.source.publication.name=debezium_fastcup debezium.source.database.server.name=fastcup debezium.source.connector.class=io.debezium.connector.postgresql.PostgresConnector
debezium.source.offset.storage.file.filename=/tmp/offsets.dat debezium.source.offset.flush.interval.ms=0 debezium.source.database.hostname=1.2.3.4
debezium.source.database.port=5432
debezium.source.database.user=123
debezium.source.database.password=123
debezium.source.database.dbname=fastcup debezium.source.table.include.list=public.matches debezium.source.column.include.list=public.matches.id,public.matches.status,public.matches.has_winner,public.matches.cancellation_reason debezium.source.snapshot.mode=never
debezium.source.plugin.name=pgoutput debezium.source.publication.autocreate.mode=filtered debezium.source.value.converter.schemas.enable=false debezium.source.heartbeat.topics.prefix=debezium-heartbeat debezium.source.heartbeat.interval.ms=5000 debezium.source.heartbeat.action.query=UPDATE debezium_heartbeat SET last_heartbeat=now()
debezium.transforms: ReplaceField
debezium.transforms.ReplaceField.type: org.apache.kafka.connect.transforms.ReplaceField$Value debezium.transforms.ReplaceField.blacklist: source,transaction,ts_ms 
quarkus.log.level=TRACE