1,142 questions
- Bountied 0
- Unanswered
- Frequent
- Score
- Trending
- Week
- Month
- Unanswered (my tags)
0
votes
0
answers
74
views
Kafka Connect REST API returns Request timed out. The worker is currently ensuring membership in the cluster
I am trying to register a Debezium MySQL connector using Kafka Connect REST API, but the request fails with a timeout error even before the connector configuration is validated.
Command used
curl -X ...
1
vote
1
answer
103
views
Understanding Debezium Snapshot
Debezium’s PostgreSQL snapshot docs note :
always
The connector performs a snapshot every time that it starts. The snapshot includes the structure and data of the captured tables. Specify this value ...
0
votes
1
answer
87
views
Capture Oracle metadata via Debezium connector
I'm sourcing Oracle data into Kafka topics using Debezium Oracle connector.
I have a source Oracle table, as below:
CREATE TABLE MYDATA.MY_USER
(
USER_ID RAW(16) DEFAULT SYS_GUID() NOT ...
0
votes
1
answer
161
views
Setup Kafka Consumers to process Debezium snapshot before current events
I am working with Java/Spring/Kafka on a new system that will consume events from both compacted topics and standard non compacted CDC topics. The events on these topics are published by a Debezium ...
0
votes
1
answer
71
views
Google Cloud PubSub Synchronous Pull: Getting One Message at a Time Instead of Batches
Problem
I'm using Google Cloud PubSub with synchronous pull and ordering enabled to consume messages from a Debezium Server setup, but I'm only receiving one message at a time instead of getting ...
0
votes
1
answer
174
views
Custom Debezium image falling with FileNotFoundException: /opt/kafka/custom-config/log4j.properties
I am trying to get debezium up and running on EKS. However i keep running into errors.
Below is the dockerfile which i have created to build the image and push it to ECR
FROM quay.io/strimzi/kafka:...
0
votes
1
answer
142
views
Cannot create second debezium connector to the same oracle DB
First, I know it is not suggested to run multiple connectors to the same DB but we have to do that in current ciscumstances, at least for a while.
Soo in current scenario, we have two separate Azure ...
0
votes
0
answers
41
views
Debezium initial snapshot on demand
I have a debezium 3.0 in my python project. Postgres-debezium connector has the following structure:
{
"name": "dbz_name",
"config": {
"connector.class&...
0
votes
0
answers
34
views
Confluent S3 Sink Connector producing millions of small files despite large flush.size and rotate.interval
The S3 connector creates approximately 1 million tiny files per hour instead of the expected larger files. Each file contains only a few records (~3KB)
RootCause :
Two Debezium CDC connectors (owned ...
0
votes
0
answers
63
views
Restart Debezium by clicking a button on the web application In the Kubernetes environment
I have 3 pods running in a Kubernetes environment. The three pods are as follows:
(1) Web application pod
(2) Oracle database
(3) Debezium
The web application is connected to an Oracle database, ...
0
votes
1
answer
73
views
How to solve undo_retention error while migration data via Debezium from table without primary key?
We are using Debezium to process migration from Oracle database to PostgreSQL.
Oracle contains a large table with hundreds of millions of rows without a primary key.
After 2-3 days of collecting data ...
2
votes
1
answer
158
views
Debezium + Flink Oracle CDC - "db history topic or its content is fully or partially missing" for some tables
I am using Flink with Debezium to consume CDC changes from Oracle DB tables via LogMiner.
For some tables, everything works fine. For example, the following table works without issues:
CREATE TABLE ...
0
votes
0
answers
80
views
Flink SQL Job: com.starrocks.data.load.stream.exception.StreamLoadFailException: Could not get load state because
I'm encountering a Flink job failure and would appreciate any input on what might be misconfigured:
2025‐07‐28 17:30:52
org.apache.flink.runtime.JobException: Recovery is suppressed by ...
0
votes
0
answers
62
views
Debezuim ui create connector
I have the following docker-compose yaml:
version: '3'
networks:
kafka-network:
driver: bridge
services:
zookeeper:
image: confluentinc/cp-zookeeper:7.6.0
environment:
...
0
votes
2
answers
98
views
how have CDC on redis?
I'm using CDC services like (Debezium) on my Mongo or Postgres but somehow I came up with situation that I need have to CDC on Redis . for example get streams of event occur in Redis like adding new ...