In order to make your issue reports as actionable as possible, please provide the following information, depending on the issue type.

Bug report

We got this ORA-00604 error for the first time, then every restart of connector kept giving this error until we cleared up offsets, schema/history topics and reran with full snapshot. So, as per the detailed issue below, it was complaining about more rows fetched than requested. However, we are in the process of migrating to 3.1.1. If it will be fixed there, then we have no worries. But, would like to know the root cause of this and get it fixed.

What Debezium connector do you use and what version?

implementation 'io.debezium:debezium-api:2.7.3.Final' implementation'io.debezium:debezium-embedded:2.7.3.Final' implementation 'org.apache.kafka:connect-runtime:3.6.1' implementation 'io.debezium:debezium-connector-oracle:2.7.3.Final' implementation 'com.oracle.database.jdbc:ojdbc8:21.6.0.0' implementation 'io.debezium:debezium-storage-kafka:2.7.3.Final'

What is the connector configuration?

decimalHandlingMode: string name: <<NAME>> class: io.debezium.connector.oracle.OracleConnector offsetTopic: <<OFFSETTOPICNAME>> offsetTopicNumberOfPartitions: 1 offsetTopicReplicationFactor: 1 heartbeatIntervalInMsecs: 100000 heartbeatQuery: SELECT * FROM MYTABLE WHERE ROWNUM <= 1 database.query.timeout.ms: 600000 .with("name", wmsDbzConnectorName) .with("connector.class", wmsDbzConnectorClass) .with("offset.storage", "org.apache.kafka.connect.storage.KafkaOffsetBackingStore") .with("offset.storage.topic", debeziumConnectorOffsetTopic) .with(DistributedConfig.OFFSET_STORAGE_PARTITIONS_CONFIG, debeziumConnectorOffsetTopicPartitions) .with(DistributedConfig.OFFSET_STORAGE_REPLICATION_FACTOR_CONFIG, debeziumConnectorOffsetTopicReplicationFactor) .with("offset.flush.interval.ms", "60000") .with("database.hostname", wmsDbHost) .with("database.port", port) .with("database.user", username) .with("database.password", password) .with("database.dbname", dbName) .with("schema.include.list", schemaList) .with("table.include.list", tableList) .with("include.schema.changes", "false") .with("topic.prefix", topicPrefix) .with("database.server.name", dbserverName) .with("snapshot.mode", snapshotMode) // It is set as initial .with("converter.schemas.enable", "false") .with("decimal.handling.mode", decimalHandlingMode) .with("heartbeat.interval.ms", heartbeatInterval) .with("heartbeat.action.query", heartbeatActionQuery) .with("database.query.timeout", 600000) .with("database.history.kafka.topic", dbAndSchemaHistoryTopic) .with("database.history.consumer.group.id", dbAndSchemaHistoryTopicConsumerGroupId) .with("schema.history.internal.kafka.topic", schemaTopic) .with("schema.history.internal.kafka.bootstrap.servers", schemaBootstrapServers) .with("schema.history.internal.consumer.security.protocol", schemaSecurityProtocol) .with("schema.history.internal.consumer.ssl.keystore.type", schemaSslKeyStoreType) .with("schema.history.internal.consumer.ssl.keystore.location", schemaSslKeystoreLocation) .with("schema.history.internal.consumer.ssl.keystore.password", schemaSslKeystorePassword) .with("schema.history.internal.consumer.ssl.truststore.type", schemaSslTrustStoreType) .with("schema.history.internal.consumer.ssl.truststore.location", schemaSslTruststoreLocation) .with("schema.history.internal.consumer.ssl.truststore.password", schemaSslTruststorePassword) .with("schema.history.internal.consumer.ssl.endpoint.identification.algorithm", sslEndpointAlgorithm) .with("schema.history.internal.producer.security.protocol", schemaSecurityProtocol) .with("schema.history.internal.producer.ssl.keystore.type", schemaSslKeyStoreType) .with("schema.history.internal.producer.ssl.keystore.location", schemaSslKeystoreLocation) .with("schema.history.internal.producer.ssl.keystore.password", schemaSslKeystorePassword) .with("schema.history.internal.producer.ssl.truststore.type", schemaSslTrustStoreType) .with("schema.history.internal.producer.ssl.truststore.location", schemaSslTruststoreLocation) .with("schema.history.internal.producer.ssl.truststore.password", schemaSslTruststorePassword) .with("schema.history.internal.producer.ssl.endpoint.identification.algorithm", sslEndpointAlgorithm) .with("bootstrap.servers", schemaBootstrapServers) .with("security.protocol", schemaSecurityProtocol) .with("ssl.keystore.location", schemaSslKeystoreLocation) .with("ssl.keystore.password", schemaSslKeystorePassword) .with("ssl.truststore.location", schemaSslTruststoreLocation) .with("ssl.truststore.password", schemaSslTruststorePassword) .with("ssl.endpoint.identification.algorithm", sslEndpointAlgorithm)

What is the captured database version and mode of deployment?

(E.g. on-premises, with a specific cloud provider, etc.)

Data base in running on a data center and is an Oracle database of version 19c.

DB Server on Dev Database runs on a 2 node RAC. The Archived log files (which Log Miner reads from) are shared to both nodes in RAC as a shared path.

What behavior do you expect?

Was expecting the retry attempt to fix the issue. But the issue seems happening again and again, even if we destroy the server and redeploy. 

What behavior do you see?

We kept on getting this ORA-00604 error (with more fetched error than requested number of rows as shown below. Every retry attempt doesn't seem to fix it at all. Even when we restart the Oracle Debezium Java connector, same issue keeps happening and stops. Only way we managed to get out of this was to clean up offset topic, schema and history topics and then run a fetch initial snapshot again.

{"@timestamp":"2025-05-08T07:32:37.645Z","ecs.version":"1.2.0","log.level":"ERROR","message":"Mining session stopped due to error.","process.thread.name":"debezium-oracleconnector-myserver-locationid-change-event-source-coordinator","log.logger":"io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource","dbz.connectorContext":"streaming","dbz.connectorName":"myserver-locationid","dbz.connectorType":"Oracle","dbz.databaseName":"MYDB","dbz.taskId":"0","error.type":"java.sql.SQLException","error.message":"ORA-00604: error occurred at recursive SQL level 1\nORA-01422: exact fetch returns more than requested number of rows\nORA-06512: at line 1\n","error.stack_trace":"java.sql.SQLException: ORA-00604: error occurred at recursive SQL level 1\nORA-01422: exact fetch returns more than requested number of rows\nORA-06512: at line 1\n\n\tat oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:630)\n\tat oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:564)\n\tat oracle.jdbc.driver.T4C8Oall.processError

Do you see the same behaviour using the latest released Debezium version?

So far, we tried 3.1.1 only for 1 week in one of the lower environments only. So far did not experience it, but even with 2.7.3, we experienced this kind of error only for first time.

Do you have the connector logs, ideally from start till finish?

Here are the logs that might help

{"@timestamp":"2025-05-08T07:32:37.645Z","ecs.version":"1.2.0","log.level":"ERROR","message":"Mining session stopped due to error.","process.thread.name":"debezium-oracleconnector-mylocation-change-event-sou rce-coordinator","log.logger":"io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource","dbz.connectorContext":"streaming","dbz.connectorName":"mylocation","dbz.connectorType":"Oracle","dbz. databaseName":"MYDB","dbz.taskId":"0","error.type":"java.sql.SQLException","error.message":"ORA-00604: error occurred at recursive SQL level 1\nORA-01422: exact fetch returns more than requested number of row s\nORA-06512: at line 1\n","error.stack_trace":"java.sql.SQLException: ORA-00604: error occurred at recursive SQL level 1\nORA-01422: exact fetch returns more than requested number of rows\nORA-06512: at line 1\n \n\tat oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:630)\n\tat oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:564)\n\tat oracle.jdbc.driver.T4C8Oall.processError(T4C8Oall.java:1151)\ n\tat oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:771)\n\tat oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:299)\n\tat oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:498)\n\tat oracle.jdbc.driver.T4C PreparedStatement.doOall8(T4CPreparedStatement.java:152)\n\tat oracle.jdbc.driver.T4CPreparedStatement.fetch(T4CPreparedStatement.java:1219)\n\tat oracle.jdbc.driver.OracleStatement.fetchMoreRows(OracleStatement. java:3785)\n\tat oracle.jdbc.driver.InsensitiveScrollableResultSet.fetchMoreRows(InsensitiveScrollableResultSet.java:825)\n\tat oracle.jdbc.driver.InsensitiveScrollableResultSet.fetchNextRows(InsensitiveScrollabl eResultSet.java:763)\n\tat oracle.jdbc.driver.InsensitiveScrollableResultSet.absoluteInternal(InsensitiveScrollableResultSet.java:735)\n\tat oracle.jdbc.driver.InsensitiveScrollableResultSet.next(InsensitiveScrol lableResultSet.java:440)\n\tat io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.hasNextWithMetricsUpdate(AbstractLogMinerEventProcessor.java:1253)\n\tat io.debezium.connector.oracle. logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:318)\n\tat io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMi nerEventProcessor.java:241)\n\tat io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:243)\n\tat io.debezium.connector.oracle.logminer.LogMiner StreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:62)\n\tat io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:313)\n\tat io.debezium.pipelin e.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:203)\n\tat io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:143)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)\n\tat java.base/java.util.concurrent.FutureTask.run(Unknown Source)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker( Unknown Source)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)\n\tat java.base/java.lang.Thread.run(Unknown Source)\nCaused by: Error : 604, Position : 0, Sql = SELECT SCN, SQL _REDO, OPERATION_CODE, TIMESTAMP, XID, CSF, TABLE_NAME, SEG_OWNER, OPERATION, USERNAME, ROW_ID, ROLLBACK, RS_ID, STATUS, INFO, SSN, THREAD#, DATA_OBJ#, DATA_OBJV#, DATA_OBJD# FROM V$LOGMNR_CONTENTS WHERE SCN > :1   AND SCN <= :2  AND (((OPERATION_CODE IN (1,2,3,7,34,36,255)) AND (SEG_OWNER IS NULL OR SEG_OWNER NOT IN ('APPQOSSYS','AUDSYS','CTXSYS','DVSYS','DBSFWUSER','DBSNMP','GGSHAREDCAP','GSMADMIN_INTERNAL','LBACSYS','M DSYS','OJVMSYS','OLAPSYS','ORDDATA','ORDSYS','OUTLN','SYS','SYSTEM','VECSYS','WMSYS','XDB'))) OR (OPERATION_CODE = 5 AND INFO NOT LIKE 'INTERNAL DDL%')), OriginalSql = SELECT SCN, SQL_REDO, OPERATION_CODE, TIMEST AMP, XID, CSF, TABLE_NAME, SEG_OWNER, OPERATION, USERNAME, ROW_ID, ROLLBACK, RS_ID, STATUS, INFO, SSN, THREAD#, DATA_OBJ#, DATA_OBJV#, DATA_OBJD# FROM V$LOGMNR_CONTENTS WHERE SCN > ? AND SCN <= ? AND (((OPERATION _CODE IN (1,2,3,7,34,36,255)) AND (SEG_OWNER IS NULL OR SEG_OWNER NOT IN ('APPQOSSYS','AUDSYS','CTXSYS','DVSYS','DBSFWUSER','DBSNMP','GGSHAREDCAP','GSMADMIN_INTERNAL','LBACSYS','MDSYS','OJVMSYS','OLAPSYS','ORDDAT A','ORDSYS','OUTLN','SYS','SYSTEM','VECSYS','WMSYS','XDB'))) OR (OPERATION_CODE = 5 AND INFO NOT LIKE 'INTERNAL DDL%')), Error Msg = ORA-00604: error occurred at recursive SQL level 1\nORA-01422: exact fetch returns more than requested number of rows\nORA-06512: at line 1\n\n\tat oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:637)\n\t... 25 more\n"} {"@timestamp":"2025-05-08T07:32:37.645Z","ecs.version":"1.2.0","log.level":"ERROR","message":"Producer failure","process.thread.name":"debezium-oracleconnector-mylocation-change-event-source-coordinator","log.logger":"io.debezium.pipeline.ErrorHandler","dbz.connectorContext":"streaming","dbz.connectorName":"mylocation","dbz.connectorType":"Oracle","dbz.databaseName":"MYDB","dbz.taskId":"0","error.type":"java.sql.SQLException","error.message":"ORA-00604: error occurred at recursive SQL level 1\nORA-01422: exact fetch returns more than requested number of rows\nORA-06512: at line 1\n","error.stack_trace":"java.sql.SQLException: ORA-00604: error occurred at recursive SQL level 1\nORA-01422: exact fetch returns more than requested number of rows\nORA-06512: at line 1\n\n\tat oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:630)\n\tat oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:564)\n\tat oracle.jdbc.driver.T4C8Oall.processError(T4C8Oall.java:1151)\n\tat oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:771)\n\tat oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:299)\n\tat oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:498)\n\tat oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:152)\n\tat oracle.jdbc.driver.T4CPreparedStatement.fetch(T4CPreparedStatement.java:1219)\n\tat oracle.jdbc.driver.OracleStatement.fetchMoreRows(OracleStatement.java:3785)\n\tat oracle.jdbc.driver.InsensitiveScrollableResultSet.fetchMoreRows(InsensitiveScrollableResultSet.java:825)\n\tat oracle.jdbc.driver.InsensitiveScrollableResultSet.fetchNextRows(InsensitiveScrollableResultSet.java:763)\n\tat oracle.jdbc.driver.InsensitiveScrollableResultSet.absoluteInternal(InsensitiveScrollableResultSet.java:735)\n\tat oracle.jdbc.driver.InsensitiveScrollableResultSet.next(InsensitiveScrollableResultSet.java:440)\n\tat io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.hasNextWithMetricsUpdate(AbstractLogMinerEventProcessor.java:1253)\n\tat io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:318)\n\tat io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:241)\n\tat io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:243)\n\tat io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:62)\n\tat io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:313)\n\tat io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:203)\n\tat io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:143)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)\n\tat java.base/java.util.concurrent.FutureTask.run(Unknown Source)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)\n\tat java.base/java.lang.Thread.run(Unknown Source)\nCaused by: Error : 604, Position : 0, Sql = SELECT SCN, SQL_REDO, OPERATION_CODE, TIMESTAMP, XID, CSF, TABLE_NAME, SEG_OWNER, OPERATION, USERNAME, ROW_ID, ROLLBACK, RS_ID, STATUS, INFO, SSN, THREAD#, DATA_OBJ#, DATA_OBJV#, DATA_OBJD# FROM V$LOGMNR_CONTENTS WHERE SCN > :1  AND SCN <= :2  AND (((OPERATION_CODE IN (1,2,3,7,34,36,255)) AND (SEG_OWNER IS NULL OR SEG_OWNER NOT IN ('APPQOSSYS','AUDSYS','CTXSYS','DVSYS','DBSFWUSER','DBSNMP','GGSHAREDCAP','GSMADMIN_INTERNAL','LBACSYS','MDSYS','OJVMSYS','OLAPSYS','ORDDATA','ORDSYS','OUTLN','SYS','SYSTEM','VECSYS','WMSYS','XDB'))) OR (OPERATION_CODE = 5 AND INFO NOT LIKE 'INTERNAL DDL%')), OriginalSql = SELECT SCN, SQL_REDO, OPERATION_CODE, TIMESTAMP, XID, CSF, TABLE_NAME, SEG_OWNER, OPERATION, USERNAME, ROW_ID, ROLLBACK, RS_ID, STATUS, INFO, SSN, THREAD#, DATA_OBJ#, DATA_OBJV#, DATA_OBJD# FROM V$LOGMNR_CONTENTS WHERE SCN > ? AND SCN <= ? AND (((OPERATION_CODE IN (1,2,3,7,34,36,255)) AND (SEG_OWNER IS NULL OR SEG_OWNER NOT IN ('APPQOSSYS','AUDSYS','CTXSYS','DVSYS','DBSFWUSER','DBSNMP','GGSHAREDCAP','GSMADMIN_INTERNAL','LBACSYS','MDSYS','OJVMSYS','OLAPSYS','ORDDATA','ORDSYS','OUTLN','SYS','SYSTEM','VECSYS','WMSYS','XDB'))) OR (OPERATION_CODE = 5 AND INFO NOT LIKE 'INTERNAL DDL%')), Error Msg = ORA-00604: error occurred at recursive SQL level 1\nORA-01422: exact fetch returns more than requested number of rows\nORA-06512: at line 1\n\n\tat oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:637)\n\t... 25 more\n"} {"@timestamp":"2025-05-08T07:32:37.645Z","ecs.version":"1.2.0","log.level":"WARN","message":"Retry 1 of unlimited retries will be attempted","process.thread.name":"debezium-oracleconnector-mylocation-change-event-source-coordinator","log.logger":"io.debezium.pipeline.ErrorHandler","dbz.connectorContext":"streaming","dbz.connectorName":"mylocation","dbz.connectorType":"Oracle","dbz.databaseName":"MYDB","dbz.taskId":"0"} {"@timestamp":"2025-05-08T07:32:37.646Z","ecs.version":"1.2.0","log.level":"INFO","message":"startScn=10454050466, endScn=10454072466","process.thread.name":"debezium-oracleconnector-mylocation-change-event-source-coordinator","log.logger":"io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource","dbz.connectorContext":"streaming","dbz.connectorName":"mylocation","dbz.connectorType":"Oracle","dbz.databaseName":"MYDB","dbz.taskId":"0"}

{"@timestamp":"2025-05-08T07:32:37.646Z","ecs.version":"1.2.0","log.level":"INFO","message":"Streaming metrics dump: LogMinerStreamingChangeEventSourceMetrics{connectorConfig=io.debezium.connector.oracle.OracleConnectorConfig@28f25d91, startTime=2025-05-03T08:10:20.054851064Z, clock=SystemClock[Z], currentScn=10454330661, offsetScn=10454053747, commitScn=10454053798, oldestScn=-1, oldestScnTime=null, currentLogFileNames=[+DATAC4/MYP0401_TTC/ONLINELOG/group_1.278.1136456769, +RECOC4/MYP0401_TTC/ONLINELOG/group_1.271.1136456771, +RECOC4/MYP0401_TTC/ONLINELOG/group_3.286.1136457505, +DATAC4/MYP0401_TTC/ONLINELOG/group_3.258.1136457505], redoLogStatuses=[+DATAC4/MYP0401_TTC/ONLINELOG/group_4.283.1136457505 | ACTIVE, +DATAC4/MYP0401_TTC/ONLINELOG/group_2.284.1136456769 | ACTIVE, +RECOC4/MYP0401_TTC/ONLINELOG/group_2.272.1136456771 | ACTIVE, +RECOC4/MYP0401_TTC/ONLINELOG/group_4.281.1136457507 | ACTIVE, +RECOC4/MYP0401_TTC/ONLINELOG/group_3.286.1136457505 | CURRENT, +DATAC4/MYP0401_TTC/ONLINELOG/group_3.258.1136457505 | CURRENT, +DATAC4/MYP0401_TTC/ONLINELOG/group_1.278.1136456769 | CURRENT, +RECOC4/MYP0401_TTC/ONLINELOG/group_1.271.1136456771 | CURRENT], databaseZoneOffset=-05:00, batchSize=23000, logSwitchCount=28, logMinerQueryCount=108887, sleepTime=2400, minimumLogsMined=4, maximumLogsMined=4, maxBatchProcessingThroughput=7007, timeDifference=3, processedRowsCount=112221467, activeTransactionCount=0, rolledBackTransactionCount=71313, oversizedTransactionCount=0, changesCount=21838769, scnFreezeCount=0, batchProcessingDuration=

{min=PT0.166320864S,max=PT1M32.431347687S,total=PT32H11M41.262532569S}

, fetchQueryDuration={min=PT0.134990427S,max=PT13.069244597S,total=PT27H34M8.417317556S}, commitDuration={min=PT0.00001067S,max=PT1M5.483521759S,total=PT54M53.789860714S}, lagFromSourceDuration={min=PT0.669716128S,max=PT10M50.408025848S,total=PT251632H36M13.342695224S}, miningSessionStartupDuration={min=PT0.0065316S,max=PT25.608641667S,total=PT1H14M26.380825614S}, parseTimeDuration={min=PT0.000007516S,max=PT0.056312347S,total=PT14M57.659953726S}, resultSetNextDuration={min=PT0.000000089S,max=PT9.790117801S,total=PT25M47.500703783S}, userGlobalAreaMemory={value=58933216,max=71515528}, processGlobalAreaMemory={value=194943496,max=451320328}, abandonedTransactionIds=[], rolledBackTransactionIds=[1e001500abc51900, 2b001200e93f1400, 1e001700c3c01900, 2b00210064401400, 2b0008009a3e1400, 2e000a00f4ff0e00, 08000300a8ac0600, 2900100001480600, 4e0001009c6c0500, 5200190027a70200]} ","process.thread.name":"debezium-oracleconnector-mylocation-change-event-source-coordinator","log.logger":"io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource","dbz.connectorContext":"streaming","dbz.connectorName":"mylocation","dbz.connectorType":"Oracle","dbz.databaseName":"MYDB","dbz.taskId":"0"}

 

How to reproduce the issue using our tutorial deployment?

Unknown

Feature request or enhancement

For feature requests or enhancements, provide this information, please:

Which use case/requirement will be addressed by the proposed feature?

Continous flow of Debezium events without interruption

Implementation ideas (optional)

<Your answer>