LogMiner session stopped due to an error frequently in prod system and the connector scn doesn't move forward post that

144 views
Skip to first unread message

Sijo Saji

unread,
Jul 27, 2026, 11:42:33 AM (7 days ago) Jul 27
to debezium
  1. CONNECTOR / PLATFORM VERSIONS

Debezium version : 3.2.6
Kafka Connect client version : 3.9.1
Oracle JDBC driver version : 19.30.0.0.0
Oracle Database version : Oracle Database 19c Enterprise Edition
Release 19.0.0.0.0 - Production
Connector framework : Debezium (Kafka Connect source/sink connectors)

  • Oracle Source connector class : io.debezium.connector.oracle.OracleConnector
  • MongoDB Source connector class : io.debezium.connector.mongodb.MongoDbConnector

  2. ISSUE OBSERVED

Recurring error on the Oracle Source connector (LogMiner-based CDC):

"LogMiner session stopped due to an error."
(io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource)

Frequency: Occurring approximately every [4-5](


) hour on average, though the
interval is inconsistent - on some days it does not occur at all, and
on other days it recurs multiple times within a few hours.

Impact / current workaround:

  • When the LogMiner session stops, the connector task fails and is
    currently being rotated (restarted as a new connector task
    instance, e.g. prod-v3 -> prod-v4 -> prod-v5 -> ... -> prod-v17,
    observed incrementing across the review window).
  • On restart, the previous committed offset is patched/re-applied so
    that CDC processing can continue from where it left off, avoiding
    a full re-snapshot.
  • This keeps the pipeline running but is a manual/operational
    mitigation, not a permanent fix - the underlying LogMiner session
    instability has not been root-caused yet.

Secondary symptom observed:

  • There have also been cases where the connector reports the message
    as successfully processed/produced (i.e. it shows up as delivered
    in DLQ/produced-message tracking), but the message still does not
    arrive at the expected downstream consumer/sink - i.e. an
    intermittent message drop despite an apparently successful publish
    acknowledgement on the source side.

Please help as we are very close to PROD deployment 

Chris Cranford

unread,
Jul 27, 2026, 11:52:07 AM (7 days ago) Jul 27
to debe...@googlegroups.com
Hi -

The most common reasons why the SCN does not move forward are:

    * Long running transaction or someone created an idle transaction that hasn't committed or rolled back.
    * Low activity on the system, offsets are therefore not updated in the offset topic.

For long-running or idle transactions, this is where using `log.mining.transaction.retention.ms` comes in handy to discard transactions after a given period of time. For low activity, this is where setting up `heartbeat.action.query` and `heartbeat.interval.ms` properties can help make sure that there is activity captured by the connector (add heartbeat table to include list) so that the offsets can be updated at a steady pace. 

If you believe neither of those are the problem, then it would be helpful to know the exact exception, as you did not share the full error.
It would also be useful if you could share the full connector configuration, in case there is a misconfiguration.

As for the DLQ and not arriving at the sink, what sink is this? Is it Debezium's JDBC sink connector or is it another vendor's sink?

Thanks,
-cc
--
You received this message because you are subscribed to the Google Groups "debezium" group.
To unsubscribe from this group and stop receiving emails from it, send an email to debezium+u...@googlegroups.com.
To view this discussion visit https://groups.google.com/d/msgid/debezium/0dea8125-50d0-471c-ab43-b4e5b1190c2cn%40googlegroups.com.

Sijo Saji

unread,
Jul 27, 2026, 1:32:16 PM (6 days ago) Jul 27
to debezium

This is the exception we got frequently and we have to setup new connector frequently due to log miner being stopped.

at oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:1023)
[2026-07-26 00:07:55,794] ERROR [oracle-source-connector-prod-v3|task-0] LogMiner session stopped due to an error. (io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource:212)
java.sql.SQLRecoverableException: IO Error: Connection reset
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.process(BufferedLogMinerStreamingChangeEventSource.java:243)
Caused by: java.net.SocketException: Connection reset
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.process(BufferedLogMinerStreamingChangeEventSource.java:243)
at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:623)
at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:268)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.execute(AbstractLogMinerStreamingChangeEventSource.java:209)
at oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:446)
at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:512)
at oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:200)
[2026-07-26 00:07:55,794] ERROR [oracle-source-connector-prod-v3|task-0] Producer failure (io.debezium.pipeline.ErrorHandler:52)
at oracle.jdbc.driver.OracleStatement.executeMaybeDescribe(OracleStatement.java:1149)
at oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:1010)
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
... 20 more
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.executeAndProcessQuery(AbstractLogMinerStreamingChangeEventSource.java:391)
at oracle.jdbc.driver.T4CMAREngineNIO.unmarshalUB1(T4CMAREngineNIO.java:487)
at java.base/java.lang.Thread.run(Unknown Source)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.executeQuery(OraclePreparedStatementWrapper.java:1102)
[2026-07-26 00:07:55,795] INFO [oracle-source-connector-prod-v3|task-0] Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:327)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:115)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:268)
at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:299)
at oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:446)
at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3761)
at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1470)
at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:163)
at oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:98)
at oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:200)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:4268)
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:147)
... 11 more
at oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:834)
at oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:834)
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:2154)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:2154)
at java.base/java.lang.Thread.run(Unknown Source)
at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:299)
at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:2171)
at oracle.jdbc.driver.OraclePreparedStatement.executeQuery(OraclePreparedStatement.java:3936)
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:147)
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.executeLogMiningStreaming(BufferedLogMinerStreamingChangeEventSource.java:156)
at java.base/sun.nio.ch.SocketChannelImpl.throwConnectionReset(Unknown Source)
at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:623)
at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:2171)
at oracle.jdbc.driver.OracleStatement.executeMaybeDescribe(OracleStatement.java:1149)
Suppressed: java.sql.SQLRecoverableException: Closed Connection
... 11 more
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:326)
at oracle.jdbc.driver.PhysicalConnection.requireOpenConnection(PhysicalConnection.java:11812)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:115)
at oracle.jdbc.driver.PhysicalConnection.requireOpenConnection(PhysicalConnection.java:11812)
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:147)
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:326)
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.executeLogMiningStreaming(BufferedLogMinerStreamingChangeEventSource.java:156)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:142)
at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:163)
at java.base/sun.nio.ch.SocketChannelImpl.read(Unknown Source)
[2026-07-26 00:07:55,795] INFO [oracle-source-connector-prod-v3|task-0] Streaming metrics at shutdown: LogMinerStreamingChangeEventSourceMetrics{connectorConfig=io.debezium.connector.oracle.OracleConnectorConfig@58133f7c, startTime=2026-07-25T15:14:25.459377968Z, clock=SystemClock[Z], currentScn=118242329479, offsetScn=118240485093, commitScn=118240518185, oldestScn=118240485094, oldestScnTime=2026-07-25T13:28:54.007Z, currentLogFileNames=[+DATA/AGICPROD/ONLINELOG/group_5.268.1096732413, +DATA/AGICPROD/ONLINELOG/group_4.265.1096731937], redoLogStatuses=[+FRA/AGICPROD/ONLINELOG/group_3.260.1096731941 | ACTIVE, +DATA/AGICPROD/ONLINELOG/group_3.264.1096731937 | ACTIVE, +DATA/AGICPROD/ONLINELOG/group_5.268.1096732413 | CURRENT, +FRA/AGICPROD/ONLINELOG/group_4.259.1096731941 | CURRENT, +DATA/AGICPROD/ONLINELOG/group_4.265.1096731937 | CURRENT, +FRA/AGICPROD/ONLINELOG/group_5.261.1096732415 | CURRENT, +DATA/AGICPROD/ONLINELOG/group_7.270.1096732419 | INACTIVE, +FRA/AGICPROD/ONLINELOG/group_7.263.1096732419 | INACTIVE, +DATA/AGICPROD/ONLINELOG/group_8.271.1096732421 | INACTIVE, +FRA/AGICPROD/ONLINELOG/group_6.262.1096732417 | INACTIVE, +DATA/AGICPROD/ONLINELOG/group_6.269.1096732415 | INACTIVE, +FRA/AGICPROD/ONLINELOG/group_8.264.1096732423 | INACTIVE, +DATA/AGICPROD/ONLINELOG/group_1.262.1096731937 | INACTIVE, +FRA/AGICPROD/ONLINELOG/group_2.258.1096731941 | INACTIVE, +DATA/AGICPROD/ONLINELOG/group_2.263.1096731937 | INACTIVE, +FRA/AGICPROD/ONLINELOG/group_1.257.1096731941 | INACTIVE], databaseZoneOffset=+08:00, batchSize=100000, logSwitchCount=160, logMinerQueryCount=4, sleepTime=1000, minimumLogsMined=52, maximumLogsMined=63, maxBatchProcessingThroughput=250, timeDifference=7, processedRowsCount=116675, activeTransactionCount=3, rolledBackTransactionCount=177, oversizedTransactionCount=0, changesCount=102, scnFreezeCount=0, batchProcessingDuration={min=PT2M32.894232874S,max=PT31M46.817021856S,total=PT43M5.776779882S}, fetchQueryDuration={min=PT2M31.17827234S,max=PT6M11.99878419S,total=PT15M43.757025367S}, commitDuration={min=PT0.00000148S,max=PT0S,total=PT0.027684351S}, lagFromSourceDuration={min=PT1H53M55.486406999S,max=PT2H28M51.861760114S,total=PT22371H33M13.571503058S}, miningSessionStartupDuration={min=PT0.022331625S,max=PT0.030438132S,total=PT0.131496059S}, parseTimeDuration={min=PT0.00000936S,max=PT0S,total=PT0.001895575S}, resultSetNextDuration={min=PT0.00000014S,max=PT27M17.053563376S,total=PT27M18.640730551S}, userGlobalAreaMemory={value=4542696,max=6328488}, processGlobalAreaMemory={value=9052952,max=55649048}, abandonedTransactionIds=[], rolledBackTransactionIds=[3c001600e73e3d00, 3c000a0042b83d00, 3c00030069c83d00, 3c001900fddf3d00, 3c000c00d6c03d00, 3c000600d6a13d00, 3c001b000dde3d00, 3c000f00f4af3d00, 3c00200019e03d00, 3c00000094e13d00]}  (io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource:217)
at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1470)
at oracle.jdbc.driver.OracleStatement.executeSQLSelect(OracleStatement.java:1661)
Caused by: java.net.SocketException: Connection reset
Suppressed: java.sql.SQLRecoverableException: Closed Connection
[2026-07-26 00:07:55,795] WARN [oracle-source-connector-prod-v3|task-0] Retry 1 of unlimited retries will be attempted (io.debezium.pipeline.ErrorHandler:125)
java.sql.SQLRecoverableException: IO Error: Connection reset
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.process(BufferedLogMinerStreamingChangeEventSource.java:231)
[2026-07-26 00:07:55,795] INFO [oracle-source-connector-prod-v3|task-0] Connected metrics set to 'false' (io.debezium.pipeline.ChangeEventSourceCoordinator:492)
at java.base/sun.nio.ch.SocketChannelImpl.throwConnectionReset(Unknown Source)
at oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:1010)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:115)
at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:512)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.executeQuery(OraclePreparedStatementWrapper.java:1102)
... 20 more
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:147)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.execute(AbstractLogMinerStreamingChangeEventSource.java:88)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.execute(AbstractLogMinerStreamingChangeEventSource.java:209)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:115)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at oracle.jdbc.driver.OraclePreparedStatement.executeQuery(OraclePreparedStatement.java:3936)
at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3761)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.execute(AbstractLogMinerStreamingChangeEventSource.java:88)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at oracle.jdbc.driver.OracleStatement.executeSQLSelect(OracleStatement.java:1661)
at java.base/sun.nio.ch.SocketChannelImpl.read(Unknown Source)
at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:4268)
at oracle.jdbc.driver.OracleStatement.prepareDefineBufferAndExecute(OracleStatement.java:1271)
at oracle.jdbc.driver.T4CMAREngineNIO.unmarshalUB1(T4CMAREngineNIO.java:487)
at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:207)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.executeAndProcessQuery(AbstractLogMinerStreamingChangeEventSource.java:391)
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.process(BufferedLogMinerStreamingChangeEventSource.java:231)
at oracle.jdbc.driver.OracleStatement.prepareDefineBufferAndExecute(OracleStatement.java:1271)
at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:207)
at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:1133)
at oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:98)
at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:1133)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:142)
at oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:1023)
[2026-07-26 00:07:55,795] INFO [oracle-source-connector-prod-v3|task-0] Offsets as shutdown: OracleOffsetContext [scn=118240485093, txId=07002000a33f2800, txSeq=9, commit_scn=["118240508546:1:67000e00c1250800","118240518185:2:3c000400cac53d00"], lcr_position=null] (io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource:218)
[2026-07-26 00:07:55,924] INFO [oracle-source-connector-prod-v3|task-0] Exception while closing a prepared statement removed from cache (io.debezium.jdbc.JdbcConnection:1487)
at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:2171)
[2026-07-26 00:07:55,924] INFO [oracle-source-connector-prod-v3|task-0] SignalProcessor stopped (io.debezium.pipeline.signal.SignalProcessor:122)
at oracle.jdbc.driver.PhysicalConnection.requireOpenConnection(PhysicalConnection.java:11812)
[2026-07-26 00:07:55,924] INFO [oracle-source-connector-prod-v3|task-0] Debezium ServiceRegistry stopped. (io.debezium.service.DefaultServiceRegistry:105)
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:2154)
java.sql.SQLRecoverableException: Closed Connection
at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:4268)
[2026-07-26 00:07:55,924] WARN [oracle-source-connector-prod-v3|task-0] Going to restart connector after 10 sec. after a retriable exception (io.debezium.connector.common.BaseSourceTask:473)
at io.debezium.jdbc.JdbcConnection.cleanupPreparedStatement(JdbcConnection.java:1484)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:281)
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at io.debezium.jdbc.JdbcConnection.cleanupPreparedStatement(JdbcConnection.java:1484)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:354)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:226)
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
[2026-07-26 00:07:55,925] INFO [oracle-source-connector-prod-v3|task-0] Exception while closing a prepared statement removed from cache (io.debezium.jdbc.JdbcConnection:1487)
at io.debezium.jdbc.JdbcConnection.cleanupPreparedStatement(JdbcConnection.java:1484)
at io.debezium.jdbc.JdbcConnection.close(JdbcConnection.java:972)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.base/java.lang.Iterable.forEach(Unknown Source)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:281)
at io.debezium.connector.oracle.OracleConnectorTask.doStop(OracleConnectorTask.java:257)
at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:4268)
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:147)
at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:491)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:79)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at io.debezium.jdbc.JdbcConnection.close(JdbcConnection.java:972)
at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:491)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:115)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:79)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:281)
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:2154)
java.sql.SQLRecoverableException: Closed Connection
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:354)
at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:2171)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:226)
at oracle.jdbc.driver.PhysicalConnection.requireOpenConnection(PhysicalConnection.java:11812)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:79)
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:147)
at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:341)
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:147)
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:238)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:466)
at java.base/java.lang.Iterable.forEach(Unknown Source)
at io.debezium.jdbc.JdbcConnection.close(JdbcConnection.java:972)
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:238)
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:238)
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:147)
at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:4268)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:79)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:115)
at io.debezium.connector.oracle.OracleConnectorTask.doStop(OracleConnectorTask.java:257)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
[2026-07-26 00:07:55,925] INFO [oracle-source-connector-prod-v3|task-0] Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close (io.debezium.util.Threads:290)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:281)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:354)
java.sql.SQLRecoverableException: Closed Connection
at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:341)
at java.base/java.lang.Thread.run(Unknown Source)
at io.debezium.jdbc.JdbcConnection.close(JdbcConnection.java:972)
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:2154)
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:238)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at oracle.jdbc.driver.PhysicalConnection.requireOpenConnection(PhysicalConnection.java:11812)
[2026-07-26 00:07:55,924] INFO [oracle-source-connector-prod-v3|task-0] Exception while closing a prepared statement removed from cache (io.debezium.jdbc.JdbcConnection:1487)
at java.base/java.lang.Iterable.forEach(Unknown Source)
at oracle.jdbc.driver.PhysicalConnection.requireOpenConnection(PhysicalConnection.java:11812)
at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:491)
at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:341)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:466)
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:4268)
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:2154)
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:226)
[2026-07-26 00:07:55,925] INFO [oracle-source-connector-prod-v3|task-0] Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close (io.debezium.util.Threads:273)
at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:2171)
java.sql.SQLRecoverableException: Closed Connection
at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:115)
at io.debezium.jdbc.JdbcConnection.cleanupPreparedStatement(JdbcConnection.java:1484)
at io.debezium.connector.oracle.OracleConnectorTask.doStop(OracleConnectorTask.java:257)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:491)
at java.base/java.lang.Thread.run(Unknown Source)
[2026-07-26 00:07:55,925] INFO [oracle-source-connector-prod-v3|task-0] Exception while closing a prepared statement removed from cache (io.debezium.jdbc.JdbcConnection:1487)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:466)
at io.debezium.connector.oracle.OracleConnectorTask.doStop(OracleConnectorTask.java:257)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:466)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:115)
at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:2171)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:341)
at java.base/java.lang.Thread.run(Unknown Source)
at java.base/java.lang.Thread.run(Unknown Source)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:354)
at java.base/java.lang.Iterable.forEach(Unknown Source)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:226)
[2026-07-26 00:07:55,926] INFO [oracle-source-connector-prod-v3|task-0] Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close (io.debezium.util.Threads:290)
[2026-07-26 00:07:55,925] INFO [oracle-source-connector-prod-v3|task-0] Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close (io.debezium.util.Threads:273)
[2026-07-26 00:07:55,925] INFO [oracle-source-connector-prod-v3|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:988)
at io.debezium.jdbc.JdbcConnection.close(JdbcConnection.java:975)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:115)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:226)
at oracle.jdbc.driver.T4C7Ocommoncall.doOLOGOFF(T4C7Ocommoncall.java:78)
at java.base/sun.nio.ch.SocketChannelImpl.read(Unknown Source)
at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:268)
at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:268)
at java.base/sun.nio.ch.SocketChannelImpl.throwConnectionReset(Unknown Source)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:79)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:115)
at java.base/java.lang.Thread.run(Unknown Source)
at oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:446)
at oracle.jdbc.driver.PhysicalConnection.close(PhysicalConnection.java:2884)
at io.debezium.connector.oracle.OracleConnectorTask.doStop(OracleConnectorTask.java:266)
at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:491)
[2026-07-26 00:07:55,927] INFO [oracle-source-connector-prod-v3|task-0] [Producer clientId=pro.opusm-agic-schemahistory] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1384)
at oracle.jdbc.driver.T4CConnection.logoff(T4CConnection.java:2016)
at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:1133)
at oracle.jdbc.driver.PhysicalConnection.close(PhysicalConnection.java:2884)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:354)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:299)
java.sql.SQLRecoverableException: IO Error: Connection reset
at oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:98)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:142)
at oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:98)
... 7 more
at oracle.jdbc.driver.T4CMAREngineNIO.unmarshalUB1(T4CMAREngineNIO.java:487)
at oracle.jdbc.driver.T4CConnection.logoff(T4CConnection.java:2016)
at io.debezium.jdbc.JdbcConnection.lambda$doClose$4(JdbcConnection.java:987)
Caused by: java.sql.SQLRecoverableException: IO Error: Connection reset
at oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:834)
... 7 more
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
Caused by: java.net.SocketException: Connection reset
at oracle.jdbc.driver.T4C7Ocommoncall.doOLOGOFF(T4C7Ocommoncall.java:78)
at oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:446)
at io.debezium.jdbc.JdbcConnection.lambda$doClose$4(JdbcConnection.java:987)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:281)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:341)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.base/sun.nio.ch.SocketChannelImpl.read(Unknown Source)
at io.debezium.jdbc.JdbcConnection.lambda$doClose$4(JdbcConnection.java:991)
at oracle.jdbc.driver.T4CConnection.logoff(T4CConnection.java:2026)
[2026-07-26 00:07:55,927] ERROR [oracle-source-connector-prod-v3|task-0] Operation jdbc-connection-close failed (io.debezium.util.Threads:339)
Caused by: java.lang.RuntimeException: java.sql.SQLRecoverableException: IO Error: Connection reset
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at java.base/java.lang.Thread.run(Unknown Source)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:142)
at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:623)
at oracle.jdbc.driver.T4CConnection.logoff(T4CConnection.java:2026)
Caused by: java.net.SocketException: Connection reset
at java.base/java.util.concurrent.FutureTask.report(Unknown Source)
at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:623)
at io.debezium.jdbc.JdbcConnection.doClose(JdbcConnection.java:985)
... 5 more
at java.base/sun.nio.ch.SocketChannelImpl.throwConnectionReset(Unknown Source)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:1133)
at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:299)
[2026-07-26 00:07:55,927] ERROR [oracle-source-connector-prod-v3|task-0] Exception while closing JDBC bean registry connection (io.debezium.connector.oracle.OracleConnectorTask:270)
at oracle.jdbc.driver.T4CMAREngineNIO.unmarshalUB1(T4CMAREngineNIO.java:487)
at oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:200)
at oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:200)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:466)
at java.base/java.util.concurrent.FutureTask.get(Unknown Source)
at io.debezium.util.Threads.runWithTimeout(Threads.java:331)
... 5 more
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:238)
java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.sql.SQLRecoverableException: IO Error: Connection reset
at oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:834)
[2026-07-26 00:07:55,929] INFO [oracle-source-connector-prod-v3|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:689)
[2026-07-26 00:07:55,929] INFO [oracle-source-connector-prod-v3|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:685)
[2026-07-26 00:07:55,929] INFO [oracle-source-connector-prod-v3|task-0] App info kafka.producer for pro.opusm-agic-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser:89)
[2026-07-26 00:07:55,929] INFO [oracle-source-connector-prod-v3|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:695)
[2026-07-26 00:07:55,929] INFO [oracle-source-connector-prod-v3|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics:689)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:142)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.execute(AbstractLogMinerStreamingChangeEventSource.java:209)
at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:163)
at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:512)
at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:2171)
at oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:1010)
at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:4268)
at oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:834)
... 9 more
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:147)
at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:63)
Suppressed: java.sql.SQLRecoverableException: Closed Connection
at oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:446)
at oracle.jdbc.driver.OraclePreparedStatement.executeQuery(OraclePreparedStatement.java:3936)
[2026-07-26 00:07:55,929] WARN [oracle-source-connector-prod-v3|task-0] WorkerSourceTask{id=oracle-source-connector-prod-v3-0} failed to poll records from SourceTask. Will retry operation. (org.apache.kafka.connect.runtime.AbstractWorkerSourceTask:468)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.execute(AbstractLogMinerStreamingChangeEventSource.java:88)
[2026-07-26 00:07:55,929] INFO [oracle-source-connector-prod-v3|task-0] Awaiting end of restart backoff period after a retriable error (io.debezium.connector.common.BaseSourceTask:450)
at java.base/sun.nio.ch.SocketChannelImpl.read(Unknown Source)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.executeLogMiningStreaming(BufferedLogMinerStreamingChangeEventSource.java:156)
at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:1133)
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.process(BufferedLogMinerStreamingChangeEventSource.java:243)
at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:299)
at java.base/sun.nio.ch.SocketChannelImpl.throwConnectionReset(Unknown Source)
at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1470)
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:326)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
... 11 more
at oracle.jdbc.driver.OraclePreparedStatementWrapper.executeQuery(OraclePreparedStatementWrapper.java:1102)
at oracle.jdbc.driver.OracleStatement.executeSQLSelect(OracleStatement.java:1661)
at java.base/java.lang.Thread.run(Unknown Source)
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.process(BufferedLogMinerStreamingChangeEventSource.java:231)
at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:268)
at oracle.jdbc.driver.OracleStatement.executeMaybeDescribe(OracleStatement.java:1149)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.executeAndProcessQuery(AbstractLogMinerStreamingChangeEventSource.java:391)
at oracle.jdbc.driver.T4CMAREngineNIO.unmarshalUB1(T4CMAREngineNIO.java:487)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:115)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:2154)
at oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:98)
at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:207)
at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3761)
at oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:200)
at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:623)
at oracle.jdbc.driver.OracleStatement.prepareDefineBufferAndExecute(OracleStatement.java:1271)
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:147)
org.apache.kafka.connect.errors.RetriableException: An exception occurred in the change event producer. This connector will be restarted.
Caused by: java.net.SocketException: Connection reset
Caused by: java.sql.SQLRecoverableException: IO Error: Connection reset
... 20 more
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at oracle.jdbc.driver.PhysicalConnection.requireOpenConnection(PhysicalConnection.java:11812)
at oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:1023)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.execute(AbstractLogMinerStreamingChangeEventSource.java:214)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:115)
[2026-07-26 00:08:05,930] INFO [oracle-source-connector-prod-v3|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.oracle.OracleSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig:1929)
[2026-07-26 00:08:05,930] INFO [oracle-source-connector-prod-v3|task-0] Attempting to restart task. (io.debezium.connector.common.BaseSourceTask:442)
[2026-07-26 00:08:05,931] INFO [oracle-source-connector-prod-v3|task-0] Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy (io.debezium.config.CommonConnectorConfig:1617)
Version 19.30.0.0.0 (io.debezium.connector.oracle.OracleConnection:115)
[2026-07-26 00:08:06,196] INFO [oracle-source-connector-prod-v3|task-0] Database Version: Oracle Database 19c Enterprise Edition Release 19.0.0.0.0 - Production
[2026-07-26 00:08:06,231] INFO [oracle-source-connector-prod-v3|task-0] Oracle MAX_STRING_SIZE is STANDARD (io.debezium.connector.oracle.OracleConnection:852)
[2026-07-26 00:08:06,261] INFO [oracle-source-connector-prod-v3|task-0] KafkaSchemaHistory Producer config: {enable.idempotence=false, batch.size=32768, bootstrap.servers=lkc-zm00wy-pdr7zg.ap-southeast-1.aws.glb.confluent.cloud:9092, buffer.memory=1048576, key.serializer=org.apache.kafka.common.serialization.StringSerializer, security.protocol=SASL_SSL, value.serializer=org.apache.kafka.common.serialization.StringSerializer, sasl.mechanism=PLAIN, sasl.jaas.config=********, max.in.flight.requests.per.connection=1, ssl.endpoint.identification.algorithm=https, client.id=pro.opusm-agic-schemahistory} (io.debezium.storage.kafka.history.KafkaSchemaHistory:250)
[2026-07-26 00:08:06,261] INFO [oracle-source-connector-prod-v3|task-0] KafkaSchemaHistory Consumer config: {key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=cg.pro.opusm-agic.t.datamart.sa.kafka-datamart.datasync-service, bootstrap.servers=lkc-zm00wy-pdr7zg.ap-southeast-1.aws.glb.confluent.cloud:9092, security.protocol=SASL_SSL, enable.auto.commit=false, sasl.mechanism=PLAIN, sasl.jaas.config=********, fetch.min.bytes=1, session.timeout.ms=10000, auto.offset.reset=earliest, ssl.endpoint.identification.algorithm=https, client.id=pro.opusm-agic-schemahistory} (io.debezium.storage.kafka.history.KafkaSchemaHistory:249)
[2026-07-26 00:08:06,261] INFO [oracle-source-connector-prod-v3|task-0] Requested thread factory for component OracleConnector, id = pro.opusm-agic named = db-history-config-check (io.debezium.util.Threads:273)
metadata.recovery.strategy = none
ssl.keystore.password = null
socket.connection.setup.timeout.max.ms = 30000
metadata.max.idle.ms = 300000
enable.metrics.push = true
interceptor.classes = []
sasl.oauthbearer.header.urlencode = false
sasl.kerberos.min.time.before.relogin = 60000
ssl.secure.random.implementation = null
sasl.oauthbearer.expected.audience = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
receive.buffer.bytes = 32768
ssl.protocol = TLSv1.3
ssl.trustmanager.algorithm = PKIX
metrics.sample.window.ms = 30000
auto.include.jmx.reporter = true
sasl.login.refresh.window.jitter = 0.05
sasl.login.callback.handler.class = null
bootstrap.servers = [lkc-zm00wy-pdr7zg.ap-southeast-1.aws.glb.confluent.cloud:9092]
ssl.truststore.location = null
reconnect.backoff.ms = 50
partitioner.ignore.keys = false
partitioner.class = null
sasl.kerberos.service.name = null
sasl.login.refresh.window.factor = 0.8
sasl.oauthbearer.scope.claim.name = scope
value.serializer = class org.apache.kafka.common.serialization.StringSerializer
send.buffer.bytes = 131072
sasl.jaas.config = [hidden]
metrics.recording.level = INFO
compression.zstd.level = 3
compression.gzip.level = -1
acks = -1
ssl.engine.factory.class = null
partitioner.availability.timeout.ms = 0
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.mechanism = PLAIN
sasl.login.class = null
retry.backoff.max.ms = 1000
reconnect.backoff.max.ms = 1000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
compression.lz4.level = 9
sasl.login.read.timeout.ms = null
metric.reporters = []
max.block.ms = 60000
transactional.id = null
key.serializer = class org.apache.kafka.common.serialization.StringSerializer
ssl.keystore.key = null
client.dns.lookup = use_all_dns_ips
sasl.login.refresh.buffer.seconds = 300
delivery.timeout.ms = 120000
ssl.key.password = null

Chris Cranford

unread,
Jul 27, 2026, 2:39:25 PM (6 days ago) Jul 27
to debe...@googlegroups.com
Hi 

So the exception is a side effect of a much deeper issue, and that is the mining loop is taking a lot of time to read the logs. The minimumLogsMined=52 and maximumLogsMined=63 is concerning. This is what is triggering the lag of nearly 2 hrs, over which LogMiner only performed 4 queries. So in short, the connector is issuing a query, waiting for data, meanwhile the connection gets dropped.

Solutions:
  • Check firewall/NAT idle timeouts between Debezium and Oracle. It needs to exceed your worst batch time, or enable TCP keepalives
    • Setting driver.oracle.net.keepAlive=true in the connector configuration
    • Check SQLNET.EXPIRE_TIME on the database and/or the connector user's profile IDLE_TIME, making sure its not too short or enabled.
  • Since you did not share your configuration, as requested, a few things to check:
    • Make sure `log.mining.query.filter.mode` is set to `in` to push table filters down to the LogMiner queries
    • Make sure to be using `log.mining.strategy` set to `online_catalog` (default in Debezium 3.x) or `hybrid` 
    • As mentioned earlier, set `log.mining.transaction.retention.ms` in case the reason for the large number of logs mined is a long transaction
  • Update to Debezium 3.6, which uses a new mining strategy to help mitigate reading too many logs in a single pass unless absolutely required

Hope that helps.
-cc

--
You received this message because you are subscribed to the Google Groups "debezium" group.
To unsubscribe from this group and stop receiving emails from it, send an email to debezium+u...@googlegroups.com.

Sijo Saji

unread,
Jul 27, 2026, 3:48:19 PM (6 days ago) Jul 27
to debezium
Some points to ask how do we determine this : log.mining.transaction.retention.ms`.
We have batch jobs running around night time and they deal in very high no. of records.
 COnfig

{
    "name": "oracle-source-connector-prod-v5",
    "config": {
        "connector.class": "io.debezium.connector.oracle.OracleConnector",
        "errors.log.include.messages": "true",
        "schema.history.internal.admin.sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"${env:kafka-message-username}\" password=\"${env:kafka-message-password}\";",
        "schema.history.internal.consumer.sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"${env:kafka-message-username}\" password=\"${env:kafka-message-password}\";",
        "consumer.override.sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"${env:kafka-message-username}\" password=\"${env:kafka-message-password}\";",
        "transforms": "filterProcessInd,filterValidations,routeRows",
        "schema.include.list": "CUSTOMER,CUSTOMER_I,OPUS_CORE",
        "producer.override.security.protocol": "SASL_SSL",
        "include.schema.changes": "false",
        "transforms.filterValidations.condition": "value == null || value.op == 'd' || value.source == null || value.source.table != 'PPPS_CSV_PROCESS_TEMP' || (value.after != null && ((value.after.schema().field('COLUMN94') != null && value.after.get('COLUMN94') == 'VALIDATION_PASS') || (value.after.schema().field('COLUMN94') != null && value.after.get('COLUMN94') == 'VALIDATION_FAIL')))",
        "snapshot.select.statement.overrides.CUSTOMER.CMUW_CLAUSE": "SELECT * FROM CUSTOMER.CMUW_CLAUSE WHERE 1=0",
        "schema.history.internal.producer.security.protocol": "SASL_SSL",
        "poll.interval.ms": "300",
        "snapshot.select.statement.overrides.CUSTOMER.CMGE_VESSEL": "SELECT * FROM CUSTOMER.CMGE_VESSEL WHERE 1=0",
        "errors.log.enable": "true",
        "snapshot.select.statement.overrides.CUSTOMER.BPGE_CHECKLIST_HDR": "SELECT * FROM CUSTOMER.BPGE_CHECKLIST_HDR WHERE 1=0",
        "key.converter": "org.apache.kafka.connect.json.JsonConverter",
        "schema.history.internal.producer.sasl.mechanism": "PLAIN",
        "consumer.override.sasl.mechanism": "PLAIN",
        "consumer.override.bootstrap.servers": "${env:KAFKA_SERVER}",
        "database.user": "${env:oracle-username}",
        "database.dbname": "${env:ORACLE_SERVICENAME}",
        "producer.override.bootstrap.servers": "${env:KAFKA_SERVER}",
        "schema.history.internal.consumer.group.id": "${env:CONSUMER_GROUP_ID}",
        "schema.history.internal.consumer.ssl.endpoint.identification.algorithm": "https",
        "consumer.override.ssl.endpoint.identification.algorithm": "https",
        "transforms.filterProcessInd.condition": "value == null || value.op == 'd' || value.source == null || value.source.table != 'CMGE_UPLOAD_FILE' || (value.after != null && ((value.after.schema().field('PROCESS_IND') != null && value.after.get('PROCESS_IND') == 'N') || (value.after.schema().field('process_ind') != null && value.after.get('process_ind') == 'N')))",
       
        "schema.history.internal.kafka.bootstrap.servers": "${env:KAFKA_SERVER}",
        "schema.history.internal.skip.unparseable.ddl": "true",
        "snapshot.select.statement.overrides.CUSTOMER.CMGE_UPLOAD_FILE": "SELECT * FROM CUSTOMER.CMGE_UPLOAD_FILE WHERE 1=0",
        "transforms.filterValidations.language": "jsr223.groovy",
        "key.converter.schemas.enable": "true",
        "schema.history.internal.producer.ssl.endpoint.identification.algorithm": "https",
        "database.password": "${env:oracle-password}",
     
        "value.converter.schemas.enable": "true",
        "name": "oracle-source-connector-prod-v5",
       
        "transforms.routeRows.type": "org.apache.kafka.connect.transforms.RegexRouter",
        "errors.tolerance": "all",
        "producer.override.sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"${env:kafka-message-username}\" password=\"${env:kafka-message-password}\";",
        "schema.history.internal.producer.sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"${env:kafka-message-username}\" password=\"${env:kafka-message-password}\";",
        "schema.history.internal.consumer.sasl.mechanism": "PLAIN",
        "schema.history.internal.admin.security.protocol": "SASL_SSL",
        "max.batch.size": "8192",
        "producer.override.ssl.endpoint.identification.algorithm": "https",
        "snapshot.mode": "no_data",
        "schema.history.internal.consumer.security.protocol": "SASL_SSL",
        "max.queue.size": "16392",
        "tasks.max": "1",
        "schema.history.internal.admin.sasl.mechanism": "PLAIN",
     
        "transforms.filterProcessInd.language": "jsr223.groovy",
        "log.mining.transaction.retention.ms": "1800000",
        "schema.history.internal.store.only.captured.tables.ddl": "true",
        "schema.history.internal.store.only.captured.databases.ddl": "true",
        "topic.prefix": "pro.opusm-agic",
        "decimal.handling.mode": "precise",
        "schema.history.internal.kafka.topic": "${env:ORACLE_SCHEMA_TOPIC}",
        "value.converter": "org.apache.kafka.connect.json.JsonConverter",
        "transforms.routeRows.replacement": "${env:MASTER_DATA_TOPIC}",
        "schema.history.internal.admin.ssl.endpoint.identification.algorithm": "https",
       
        "database.connection.adapter": "logminer",
       
        "time.precision.mode": "connect",
        "snapshot.select.statement.overrides.CUSTOMER.PPPS_CSV_PROCESS_TEMP": "SELECT * FROM CUSTOMER.PPPS_CSV_PROCESS_TEMP WHERE 1=0",
        "transforms.filterValidations.type": "io.debezium.transforms.Filter",
        "database.port": "${env:ORACLE_PORT}",
        "snapshot.select.statement.overrides.CUSTOMER.CMGE_CODEREL_DET": "SELECT * FROM CUSTOMER.CMGE_CODEREL_DET WHERE 1=0",
        "snapshot.select.statement.overrides.CUSTOMER.ITUW_CUSTAPP_CPUPD_REQ_HDR": "SELECT * FROM CUSTOMER.ITUW_CUSTAPP_CPUPD_REQ_HDR WHERE 1=0",
        "transforms.filterProcessInd.type": "io.debezium.transforms.Filter",
        "log.mining.query.filter.mode": "in",
        "database.hostname": "${env:ORACLE_HOSTNAME}",
        "consumer.override.security.protocol": "SASL_SSL",
        "snapshot.select.statement.overrides.CUSTOMER.CMUW_NVIC": "SELECT * FROM CUSTOMER.CMUW_NVIC WHERE 1=0",
        "snapshot.select.statement.overrides.CUSTOMER.CMUW_QUESTION": "SELECT * FROM CUSTOMER.CMUW_QUESTION WHERE 1=0",
        "snapshot.select.statement.overrides.CUSTOMER.IRBM_EINVOICE": "SELECT * FROM CUSTOMER.IRBM_EINVOICE WHERE 1=0",
        "table.include.list": "TEST_TABLE"
        "transforms.routeRows.regex": ".*",
        "producer.override.sasl.mechanism": "PLAIN"
    },
    "tasks": [
        {
            "connector": "oracle-source-connector-prod-v5",
            "task": 0
        }
    ],
    "type": "source"
}

Chris Cranford

unread,
Jul 28, 2026, 12:54:07 AM (6 days ago) Jul 28
to debe...@googlegroups.com
Hi -

It's not about the volume of records in the transaction, it's about how long a single transaction executes in database time, not capture time. What I mean is a transaction could execute on the database in 10 minutes, but due to read IO, capture time could take 20 minutes because Oracle is optimized for log writes, not log reads. So if you set the retention time to 15 minutes, that transaction would still be consumed because we compute the delta based on database execution time, not capture time.

So you set `log.mining.transaction.retention.ms` to what you believe is your longest real transaction.

However, we have seen some environments start ETL jobs that run for 12+ hours, and frankly that's simply bad design. An open transaction should ideally be something that is relatively short lived, a few seconds to a few minutes and nothing that spans hours. 

HTH,
-cc

Chris Cranford

unread,
Jul 28, 2026, 12:55:56 AM (6 days ago) Jul 28
to debe...@googlegroups.com
Hi -

One follow-up regarding the configuration. I notice you haven't customized `log.mining.batch.size.*` settings. If you have high bursts of activity, you might want to start by doubling the defaults, measure and see if that helps. This only applies if you're using Debezium 3.5 or earlier. If you're using Debezium 3.6+, then please disregard as the `log.mining.batch.size.*` properties were deprecated and removed.

-cc

Sijo Saji

unread,
Jul 28, 2026, 5:45:17 AM (6 days ago) Jul 28
to debezium

So we have upgraded debizium  version to 3.6.0 Final. And this is our updated config we applied in lower env:

{
    "name": "oracle-source-connector-dry-run-3-6",
    "config": {
        "connector.class": "io.debezium.connector.oracle.OracleConnector",
        "database.query.timeout.ms": 0,

        "errors.log.include.messages": "true",
        "schema.history.internal.admin.sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"${env:kafka-message-username}\" password=\"${env:kafka-message-password}\";",
        "schema.history.internal.consumer.sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"${env:kafka-message-username}\" password=\"${env:kafka-message-password}\";",
        "consumer.override.sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"${env:kafka-message-username}\" password=\"${env:kafka-message-password}\";",
        "transforms": "filterProcessInd,filterValidations,routeRows",
        "schema.include.list": "CUSTOMER,CUSTOMER_I,OPUS_CORE",
        "producer.override.security.protocol": "SASL_SSL",
        "include.schema.changes": "false",
        "driver.oracle.net.keepAlive": "true",

        "schema.history.internal.producer.security.protocol": "SASL_SSL",
        "poll.interval.ms": "300",
        "errors.log.enable": "true",

        "key.converter": "org.apache.kafka.connect.json.JsonConverter",
        "schema.history.internal.producer.sasl.mechanism": "PLAIN",
        "consumer.override.sasl.mechanism": "PLAIN",
        "consumer.override.bootstrap.servers": "${env:KAFKA_SERVER}",
        "database.user": "${env:oracle-username}",
        "database.dbname": "${env:ORACLE_SERVICENAME}",
        "producer.override.bootstrap.servers": "${env:KAFKA_SERVER}",
        "schema.history.internal.consumer.group.id": "${env:CONSUMER_GROUP_ID}",
        "schema.history.internal.consumer.ssl.endpoint.identification.algorithm": "https",
        "consumer.override.ssl.endpoint.identification.algorithm": "https",
        "schema.history.internal.kafka.bootstrap.servers": "${env:KAFKA_SERVER}",
        "schema.history.internal.skip.unparseable.ddl": "true",
        "transforms.filterValidations.language": "jsr223.groovy",
        "key.converter.schemas.enable": "true",
        "schema.history.internal.producer.ssl.endpoint.identification.algorithm": "https",
        "database.password": "${env:oracle-password}",
        "value.converter.schemas.enable": "true",
        "transforms.routeRows.type": "org.apache.kafka.connect.transforms.RegexRouter",
        "errors.tolerance": "all",
        "producer.override.sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"${env:kafka-message-username}\" password=\"${env:kafka-message-password}\";",
        "schema.history.internal.producer.sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"${env:kafka-message-username}\" password=\"${env:kafka-message-password}\";",
        "schema.history.internal.consumer.sasl.mechanism": "PLAIN",
        "schema.history.internal.admin.security.protocol": "SASL_SSL",
        "max.batch.size": "8192",
        "producer.override.ssl.endpoint.identification.algorithm": "https",
        "snapshot.mode": "initial",

        "schema.history.internal.consumer.security.protocol": "SASL_SSL",
        "max.queue.size": "16392",
        "tasks.max": "1",
        "schema.history.internal.admin.sasl.mechanism": "PLAIN",
        "transforms.filterProcessInd.language": "jsr223.groovy",
        "log.mining.transaction.retention.ms": "3600000",

        "schema.history.internal.store.only.captured.tables.ddl": "true",
        "schema.history.internal.store.only.captured.databases.ddl": "true",
        "topic.prefix": "pre.opusm-agic",

        "decimal.handling.mode": "precise",
        "schema.history.internal.kafka.topic": "${env:ORACLE_SCHEMA_TOPIC}",
        "value.converter": "org.apache.kafka.connect.json.JsonConverter",
        "transforms.routeRows.replacement": "pre.opusm-agic.datamart.covernote-topic.uatproj",
        "schema.history.internal.admin.ssl.endpoint.identification.algorithm": "https",
     
        "database.connection.adapter": "logminer_unbuffered",
       
        "time.precision.mode": "connect",

     
        "transforms.filterValidations.type": "io.debezium.transforms.Filter",
        "database.port": "${env:ORACLE_PORT}",
        "transforms.filterProcessInd.type": "io.debezium.transforms.Filter",
        "log.mining.query.filter.mode": "in",
        "database.hostname": "${env:ORACLE_HOSTNAME}",
        "consumer.override.security.protocol": "SASL_SSL",
        "table.include.list": "",

        "transforms.routeRows.regex": ".*",
        "producer.override.sasl.mechanism": "PLAIN"
    }
}


And this latest logs we got in prod 

[2026-07-28 17:04:54,611] INFO [oracle-source-connector-prod-v26|task-0|offsets] WorkerSourceTask{id=oracle-source-connector-prod-v26-0} Committing offsets for 20 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask:236)
[2026-07-28 17:07:34,616] INFO [oracle-source-connector-prod-v26|task-0|offsets] WorkerSourceTask{id=oracle-source-connector-prod-v26-0} Committing offsets for 26 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask:236)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:1023)
at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:1133)
at java.base/java.lang.Thread.run(Unknown Source)
at oracle.jdbc.driver.OracleStatement.executeSQLSelect(OracleStatement.java:1661)
at oracle.jdbc.driver.PhysicalConnection.requireOpenConnection(PhysicalConnection.java:11812)
... 20 more

Caused by: java.net.SocketException: Connection reset
at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3761)
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:147)
at oracle.jdbc.driver.OraclePreparedStatement.executeQuery(OraclePreparedStatement.java:3936)
... 11 more
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.execute(AbstractLogMinerStreamingChangeEventSource.java:88)
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.process(BufferedLogMinerStreamingChangeEventSource.java:243)
at oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:200)
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:147)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.executeQuery(OraclePreparedStatementWrapper.java:1102)
at java.base/java.lang.Thread.run(Unknown Source)
at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:2171)

java.sql.SQLRecoverableException: IO Error: Connection reset
Suppressed: java.sql.SQLRecoverableException: Closed Connection

java.sql.SQLRecoverableException: IO Error: Connection reset
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:268)
at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:299)
at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:207)
at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:163)
at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:4268)
at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:2171)
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:2154)
at java.base/sun.nio.ch.SocketChannelImpl.throwConnectionReset(Unknown Source)
at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3761)
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.executeLogMiningStreaming(BufferedLogMinerStreamingChangeEventSource.java:156)
[2026-07-28 17:17:44,002] ERROR [oracle-source-connector-prod-v26|task-0] LogMiner session stopped due to an error. (io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource:212)
at oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:446)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:115)
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
[2026-07-28 17:17:44,002] ERROR [oracle-source-connector-prod-v26|task-0] Producer failure (io.debezium.pipeline.ErrorHandler:52)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.executeAndProcessQuery(AbstractLogMinerStreamingChangeEventSource.java:391)
at oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:1010)
at oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:834)
at oracle.jdbc.driver.OracleStatement.prepareDefineBufferAndExecute(OracleStatement.java:1271)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:142)

Caused by: java.net.SocketException: Connection reset
at oracle.jdbc.driver.OracleStatement.prepareDefineBufferAndExecute(OracleStatement.java:1271)
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.process(BufferedLogMinerStreamingChangeEventSource.java:231)
at oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:1023)
at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1470)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.executeQuery(OraclePreparedStatementWrapper.java:1102)

at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at oracle.jdbc.driver.OracleStatement.executeSQLSelect(OracleStatement.java:1661)
at oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:98)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.execute(AbstractLogMinerStreamingChangeEventSource.java:88)
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:147)
at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:512)
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:326)
at oracle.jdbc.driver.T4CMAREngineNIO.unmarshalUB1(T4CMAREngineNIO.java:487)
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.process(BufferedLogMinerStreamingChangeEventSource.java:231)
at java.base/sun.nio.ch.SocketChannelImpl.read(Unknown Source)
at java.base/sun.nio.ch.SocketChannelImpl.throwConnectionReset(Unknown Source)
at oracle.jdbc.driver.PhysicalConnection.requireOpenConnection(PhysicalConnection.java:11812)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.execute(AbstractLogMinerStreamingChangeEventSource.java:209)
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:326)
at oracle.jdbc.driver.OracleStatement.executeMaybeDescribe(OracleStatement.java:1149)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.process(BufferedLogMinerStreamingChangeEventSource.java:243)
at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:1133)
at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:4268)
at oracle.jdbc.driver.OracleStatement.executeMaybeDescribe(OracleStatement.java:1149)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:115)
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:147)
... 11 more
at oracle.jdbc.driver.OraclePreparedStatement.executeQuery(OraclePreparedStatement.java:3936)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.execute(AbstractLogMinerStreamingChangeEventSource.java:209)
at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1470)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.executeAndProcessQuery(AbstractLogMinerStreamingChangeEventSource.java:391)
at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:623)
at oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:446)
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:2154)
Suppressed: java.sql.SQLRecoverableException: Closed Connection
at java.base/sun.nio.ch.SocketChannelImpl.read(Unknown Source)
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.executeLogMiningStreaming(BufferedLogMinerStreamingChangeEventSource.java:156)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:115)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:207)
at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:623)
at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:512)
[2026-07-28 17:17:44,003] INFO [oracle-source-connector-prod-v26|task-0] Connected metrics set to 'false' (io.debezium.pipeline.ChangeEventSourceCoordinator:492)
at oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:98)
[2026-07-28 17:17:44,002] WARN [oracle-source-connector-prod-v26|task-0] Retry 1 of unlimited retries will be attempted (io.debezium.pipeline.ErrorHandler:125)
[2026-07-28 17:17:44,003] INFO [oracle-source-connector-prod-v26|task-0] Offsets as shutdown: OracleOffsetContext [scn=118401943443, txId=49000700147f6c00, txSeq=1, commit_scn=["118402063386:1:6800170014340600","118402063370:2:370017002a293d00"], lcr_position=null] (io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource:218)
at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:299)
at oracle.jdbc.driver.T4CMAREngineNIO.unmarshalUB1(T4CMAREngineNIO.java:487)
[2026-07-28 17:17:44,003] INFO [oracle-source-connector-prod-v26|task-0] Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:327)
at oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:200)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:142)
at oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:834)
at oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:1010)
at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:163)
... 20 more
at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:268)
[2026-07-28 17:17:44,002] INFO [oracle-source-connector-prod-v26|task-0] Streaming metrics at shutdown: LogMinerStreamingChangeEventSourceMetrics{connectorConfig=io.debezium.connector.oracle.OracleConnectorConfig@7c575aa8, startTime=2026-07-28T00:06:47.264292805Z, clock=SystemClock[Z], currentScn=118406485607, offsetScn=118401943443, commitScn=118402063386, oldestScn=118401943444, oldestScnTime=2026-07-28T08:25:20.008Z, currentLogFileNames=[+DATA/AGICPROD/ONLINELOG/group_3.264.1096731937, +DATA/AGICPROD/ONLINELOG/group_7.270.1096732419], redoLogStatuses=[+DATA/AGICPROD/ONLINELOG/group_4.265.1096731937 | ACTIVE, +FRA/AGICPROD/ONLINELOG/group_4.259.1096731941 | ACTIVE, +FRA/AGICPROD/ONLINELOG/group_7.263.1096732419 | ACTIVE, +DATA/AGICPROD/ONLINELOG/group_7.270.1096732419 | ACTIVE, +FRA/AGICPROD/ONLINELOG/group_6.262.1096732417 | ACTIVE, +DATA/AGICPROD/ONLINELOG/group_2.263.1096731937 | ACTIVE, +FRA/AGICPROD/ONLINELOG/group_2.258.1096731941 | ACTIVE, +DATA/AGICPROD/ONLINELOG/group_1.262.1096731937 | ACTIVE, +FRA/AGICPROD/ONLINELOG/group_1.257.1096731941 | ACTIVE, +DATA/AGICPROD/ONLINELOG/group_5.268.1096732413 | ACTIVE, +FRA/AGICPROD/ONLINELOG/group_5.261.1096732415 | ACTIVE, +DATA/AGICPROD/ONLINELOG/group_6.269.1096732415 | ACTIVE, +DATA/AGICPROD/ONLINELOG/group_8.271.1096732421 | CURRENT, +FRA/AGICPROD/ONLINELOG/group_3.260.1096731941 | CURRENT, +DATA/AGICPROD/ONLINELOG/group_3.264.1096731937 | CURRENT, +FRA/AGICPROD/ONLINELOG/group_8.264.1096732423 | CURRENT], databaseZoneOffset=+08:00, batchSize=100000, logSwitchCount=2169, logMinerQueryCount=2278, sleepTime=0, minimumLogsMined=2, maximumLogsMined=269, maxBatchProcessingThroughput=5340, timeDifference=8, processedRowsCount=8967545, activeTransactionCount=2, rolledBackTransactionCount=382651, oversizedTransactionCount=0, changesCount=35501, scnFreezeCount=0, batchProcessingDuration={min=PT0.639347989S,max=PT12M14.123892061S,total=PT7H13M28.10112823S}, fetchQueryDuration={min=PT0.207066367S,max=PT5M18.619886257S,total=PT6H26M52.650616992S}, commitDuration={min=PT0.00000169S,max=PT0.050513443S,total=PT13.668361433S}, lagFromSourceDuration={min=PT1.441068668S,max=PT40M45.945125442S,total=PT411540H28M42.464501588S}, miningSessionStartupDuration={min=PT0.020747526S,max=PT0.069216842S,total=PT1M2.670007576S}, parseTimeDuration={min=PT0.00000383S,max=PT0.005390883S,total=PT1.180949013S}, resultSetNextDuration={min=PT0.00000012S,max=PT4M2.05333837S,total=PT27M34.935968234S}, userGlobalAreaMemory={value=70286208,max=96499408}, processGlobalAreaMemory={value=74785560,max=162800408}, abandonedTransactionIds=[11001f008db31900, 1e001d00f4ee2800], rolledBackTransactionIds=[67000900c5660800, 3a000300448e2100, 1b001d003db45100, 38001700c7cf4900, 4e00040043034300, 58000a000d1e1200, 27001000791e2900, 500018006d052800, 61000900a3b70a00, 300001006ab64e00]}  (io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource:217)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:115)
[2026-07-28 17:17:44,256] INFO [oracle-source-connector-prod-v26|task-0] SignalProcessor stopped (io.debezium.pipeline.signal.SignalProcessor:122)
[2026-07-28 17:17:44,256] WARN [oracle-source-connector-prod-v26|task-0] Going to restart connector after 10 sec. after a retriable exception (io.debezium.connector.common.BaseSourceTask:473)
[2026-07-28 17:17:44,256] INFO [oracle-source-connector-prod-v26|task-0] Debezium ServiceRegistry stopped. (io.debezium.service.DefaultServiceRegistry:105)
at oracle.jdbc.driver.PhysicalConnection.requireOpenConnection(PhysicalConnection.java:11812)
at io.debezium.jdbc.JdbcConnection.cleanupPreparedStatement(JdbcConnection.java:1484)
at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:2171)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:281)
at java.base/java.lang.Iterable.forEach(Unknown Source)

at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at io.debezium.connector.oracle.OracleConnectorTask.doStop(OracleConnectorTask.java:257)

at io.debezium.jdbc.JdbcConnection.cleanupPreparedStatement(JdbcConnection.java:1484)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:354)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:466)
at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:491)
at java.base/java.lang.Iterable.forEach(Unknown Source)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)

at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:281)
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:2154)
[2026-07-28 17:17:44,257] INFO [oracle-source-connector-prod-v26|task-0] Exception while closing a prepared statement removed from cache (io.debezium.jdbc.JdbcConnection:1487)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:226)

at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:354)
java.sql.SQLRecoverableException: Closed Connection
at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:491)
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:238)
at io.debezium.jdbc.JdbcConnection.close(JdbcConnection.java:972)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:79)

at io.debezium.jdbc.JdbcConnection.close(JdbcConnection.java:972)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:4268)

at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:2171)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
[2026-07-28 17:17:44,257] INFO [oracle-source-connector-prod-v26|task-0] Exception while closing a prepared statement removed from cache (io.debezium.jdbc.JdbcConnection:1487)
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:2154)

at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:115)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at io.debezium.jdbc.JdbcConnection.close(JdbcConnection.java:972)

at oracle.jdbc.driver.PhysicalConnection.requireOpenConnection(PhysicalConnection.java:11812)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:79)
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:115)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at java.base/java.lang.Thread.run(Unknown Source)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:226)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at java.base/java.lang.Thread.run(Unknown Source)
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:238)

at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:341)
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:147)
at io.debezium.connector.oracle.OracleConnectorTask.doStop(OracleConnectorTask.java:257)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:226)
at io.debezium.connector.oracle.OracleConnectorTask.doStop(OracleConnectorTask.java:257)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:115)
java.sql.SQLRecoverableException: Closed Connection

at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:238)
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:147)
java.sql.SQLRecoverableException: Closed Connection
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:2154)
at java.base/java.lang.Iterable.forEach(Unknown Source)
[2026-07-28 17:17:44,257] INFO [oracle-source-connector-prod-v26|task-0] Exception while closing a prepared statement removed from cache (io.debezium.jdbc.JdbcConnection:1487)
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:147)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:115)

java.sql.SQLRecoverableException: Closed Connection
at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:4268)
at io.debezium.jdbc.JdbcConnection.close(JdbcConnection.java:972)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:281)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:79)
[2026-07-28 17:17:44,256] INFO [oracle-source-connector-prod-v26|task-0] Exception while closing a prepared statement removed from cache (io.debezium.jdbc.JdbcConnection:1487)
at oracle.jdbc.driver.PhysicalConnection.requireOpenConnection(PhysicalConnection.java:11812)
at java.base/java.lang.Iterable.forEach(Unknown Source)
at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:2171)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:115)
at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:341)

at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:79)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:115)
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:341)
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:147)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:466)
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:147)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)

at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at io.debezium.jdbc.JdbcConnection.cleanupPreparedStatement(JdbcConnection.java:1484)
at java.base/java.lang.Iterable.forEach(Unknown Source)
at io.debezium.jdbc.JdbcConnection.close(JdbcConnection.java:972)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:354)
at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:491)

at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:4268)
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:147)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:466)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)

at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:2171)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.sql.SQLRecoverableException: Closed Connection
at io.debezium.connector.oracle.OracleConnectorTask.doStop(OracleConnectorTask.java:257)
java.sql.SQLRecoverableException: Closed Connection
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:2154)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:466)
at io.debezium.jdbc.JdbcConnection.cleanupPreparedStatement(JdbcConnection.java:1484)

at io.debezium.jdbc.JdbcConnection.cleanupPreparedStatement(JdbcConnection.java:1484)
at io.debezium.connector.oracle.OracleConnectorTask.doStop(OracleConnectorTask.java:257)
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:2154)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:79)

at java.base/java.lang.Iterable.forEach(Unknown Source)
at io.debezium.jdbc.JdbcConnection.close(JdbcConnection.java:972)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:281)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:354)
[2026-07-28 17:17:44,257] INFO [oracle-source-connector-prod-v26|task-0] Exception while closing a prepared statement removed from cache (io.debezium.jdbc.JdbcConnection:1487)
at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:2171)
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:238)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:281)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:466)
at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:4268)
at io.debezium.jdbc.JdbcConnection.cleanupPreparedStatement(JdbcConnection.java:1484)
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:2154)
at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:4268)

at java.base/java.lang.Thread.run(Unknown Source)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:354)
at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:341)
at java.base/java.lang.Thread.run(Unknown Source)
at oracle.jdbc.driver.PhysicalConnection.requireOpenConnection(PhysicalConnection.java:11812)
at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:491)
at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:491)
at java.base/java.lang.Thread.run(Unknown Source)
at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:341)

at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:226)
at oracle.jdbc.driver.PhysicalConnection.requireOpenConnection(PhysicalConnection.java:11812)
at io.debezium.connector.oracle.OracleConnectorTask.doStop(OracleConnectorTask.java:257)
[2026-07-28 17:17:44,257] INFO [oracle-source-connector-prod-v26|task-0] Exception while closing a prepared statement removed from cache (io.debezium.jdbc.JdbcConnection:1487)
at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:2171)

at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:238)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:226)
at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:491)
at oracle.jdbc.driver.PhysicalConnection.requireOpenConnection(PhysicalConnection.java:11812)
at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:4268)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:354)
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:281)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:226)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:79)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:354)
at io.debezium.jdbc.JdbcConnection.cleanupPreparedStatement(JdbcConnection.java:1484)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:147)

at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:281)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
[2026-07-28 17:17:44,258] INFO [oracle-source-connector-prod-v26|task-0] Exception while closing a prepared statement removed from cache (io.debezium.jdbc.JdbcConnection:1487)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:79)
at oracle.jdbc.driver.PhysicalConnection.requireOpenConnection(PhysicalConnection.java:11812)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:466)
at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:4268)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:466)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:226)
at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:491)
[2026-07-28 17:17:44,258] INFO [oracle-source-connector-prod-v26|task-0] Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close (io.debezium.util.Threads:290)
[2026-07-28 17:17:44,258] INFO [oracle-source-connector-prod-v26|task-0] Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close (io.debezium.util.Threads:273)
at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:341)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.sql.SQLRecoverableException: Closed Connection
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:238)
at io.debezium.connector.oracle.OracleConnectorTask.doStop(OracleConnectorTask.java:257)
at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:341)

at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:2154)
at io.debezium.jdbc.JdbcConnection.close(JdbcConnection.java:972)
at java.base/java.lang.Thread.run(Unknown Source)
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:238)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:115)
at java.base/java.lang.Iterable.forEach(Unknown Source)
[2026-07-28 17:17:44,258] INFO [oracle-source-connector-prod-v26|task-0] Requested thread factory for component JdbcConnection, id = JdbcConnection named = jdbc-connection-close (io.debezium.util.Threads:273)
at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:2171)
[2026-07-28 17:17:44,258] INFO [oracle-source-connector-prod-v26|task-0] Creating thread debezium-jdbcconnection-JdbcConnection-jdbc-connection-close (io.debezium.util.Threads:290)
at java.base/java.lang.Thread.run(Unknown Source)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
[2026-07-28 17:17:44,258] INFO [oracle-source-connector-prod-v26|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:988)
at oracle.jdbc.driver.T4CConnection.logoff(T4CConnection.java:2026)
at oracle.jdbc.driver.T4CConnection.logoff(T4CConnection.java:2016)
at java.base/java.util.concurrent.FutureTask.report(Unknown Source)
at io.debezium.jdbc.JdbcConnection.lambda$doClose$4(JdbcConnection.java:987)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:115)
at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:341)

Caused by: java.net.SocketException: Connection reset
... 5 more
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:142)
at java.base/java.lang.Thread.run(Unknown Source)
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:238)
at io.debezium.jdbc.JdbcConnection.doClose(JdbcConnection.java:985)
[2026-07-28 17:17:44,260] ERROR [oracle-source-connector-prod-v26|task-0] Operation jdbc-connection-close failed (io.debezium.util.Threads:339)
at java.base/sun.nio.ch.SocketChannelImpl.read(Unknown Source)
at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:623)
at java.base/sun.nio.ch.SocketChannelImpl.throwConnectionReset(Unknown Source)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)

java.sql.SQLRecoverableException: IO Error: Connection reset
[2026-07-28 17:17:44,260] ERROR [oracle-source-connector-prod-v26|task-0] Exception while closing JDBC bean registry connection (io.debezium.connector.oracle.OracleConnectorTask:270)

at oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:200)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:466)
at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:268)

at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:226)

java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.sql.SQLRecoverableException: IO Error: Connection reset
at io.debezium.connector.oracle.OracleConnectorTask.doStop(OracleConnectorTask.java:266)
at io.debezium.jdbc.JdbcConnection.lambda$doClose$4(JdbcConnection.java:987)
at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:299)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at oracle.jdbc.driver.PhysicalConnection.close(PhysicalConnection.java:2884)
at oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:834)
at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:491)
... 7 more

Caused by: java.sql.SQLRecoverableException: IO Error: Connection reset
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at oracle.jdbc.driver.T4CConnection.logoff(T4CConnection.java:2026)
at oracle.jdbc.driver.PhysicalConnection.close(PhysicalConnection.java:2884)
at io.debezium.util.Threads.runWithTimeout(Threads.java:331)
at java.base/java.lang.Thread.run(Unknown Source)
at oracle.jdbc.driver.T4C7Ocommoncall.doOLOGOFF(T4C7Ocommoncall.java:78)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:354)
... 5 more
at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:1133)
at io.debezium.jdbc.JdbcConnection.close(JdbcConnection.java:975)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:79)

Caused by: java.net.SocketException: Connection reset
at java.base/java.util.concurrent.FutureTask.get(Unknown Source)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:281)
at oracle.jdbc.driver.T4CMAREngineNIO.unmarshalUB1(T4CMAREngineNIO.java:487)
at java.base/sun.nio.ch.SocketChannelImpl.throwConnectionReset(Unknown Source)

Caused by: java.lang.RuntimeException: java.sql.SQLRecoverableException: IO Error: Connection reset
at oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:446)
at io.debezium.jdbc.JdbcConnection.lambda$doClose$4(JdbcConnection.java:991)

at oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:98)
at oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:200)
at oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:446)

at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:1133)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:142)
... 7 more
at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:268)
[2026-07-28 17:17:44,260] INFO [oracle-source-connector-prod-v26|task-0] [Producer clientId=pro.opusm-agic-schemahistory] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1384)
at oracle.jdbc.driver.T4CMAREngineNIO.unmarshalUB1(T4CMAREngineNIO.java:487)
at java.base/sun.nio.ch.SocketChannelImpl.read(Unknown Source)
at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:623)
at oracle.jdbc.driver.T4CConnection.logoff(T4CConnection.java:2016)
at oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:98)
at oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:834)
at oracle.jdbc.driver.T4C7Ocommoncall.doOLOGOFF(T4C7Ocommoncall.java:78)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:115)
at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:299)
[2026-07-28 17:17:44,262] INFO [oracle-source-connector-prod-v26|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:685)
[2026-07-28 17:17:44,262] INFO [oracle-source-connector-prod-v26|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:689)
[2026-07-28 17:17:44,262] INFO [oracle-source-connector-prod-v26|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics:689)
[2026-07-28 17:17:44,262] INFO [oracle-source-connector-prod-v26|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:695)
... 20 more
at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:163)
... 9 more
at java.base/sun.nio.ch.SocketChannelImpl.throwConnectionReset(Unknown Source)
[2026-07-28 17:17:44,263] WARN [oracle-source-connector-prod-v26|task-0] WorkerSourceTask{id=oracle-source-connector-prod-v26-0} failed to poll records from SourceTask. Will retry operation. (org.apache.kafka.connect.runtime.AbstractWorkerSourceTask:468)
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.process(BufferedLogMinerStreamingChangeEventSource.java:231)
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:2154)
at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:63)
at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:4268)
at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:268)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.executeAndProcessQuery(AbstractLogMinerStreamingChangeEventSource.java:391)

org.apache.kafka.connect.errors.RetriableException: An exception occurred in the change event producer. This connector will be restarted.
at oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:1023)
at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:299)
at oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:1010)
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:147)
at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:207)
at oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:200)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:142)

Caused by: java.sql.SQLRecoverableException: IO Error: Connection reset
at java.base/java.lang.Thread.run(Unknown Source)
... 11 more
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:147)
at oracle.jdbc.driver.OraclePreparedStatement.executeQuery(OraclePreparedStatement.java:3936)
at java.base/sun.nio.ch.SocketChannelImpl.read(Unknown Source)
at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:623)
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:115)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.executeQuery(OraclePreparedStatementWrapper.java:1102)
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.process(BufferedLogMinerStreamingChangeEventSource.java:243)
at oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:98)
at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:2171)
at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1470)
[2026-07-28 17:17:44,263] INFO [oracle-source-connector-prod-v26|task-0] Awaiting end of restart backoff period after a retriable error (io.debezium.connector.common.BaseSourceTask:450)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:834)
[2026-07-28 17:17:44,262] INFO [oracle-source-connector-prod-v26|task-0] App info kafka.producer for pro.opusm-agic-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser:89)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at oracle.jdbc.driver.OracleStatement.executeSQLSelect(OracleStatement.java:1661)
at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3761)
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:326)

Caused by: java.net.SocketException: Connection reset
at oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:446)

at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at oracle.jdbc.driver.PhysicalConnection.requireOpenConnection(PhysicalConnection.java:11812)
at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:1133)
Suppressed: java.sql.SQLRecoverableException: Closed Connection
at oracle.jdbc.driver.T4CMAREngineNIO.unmarshalUB1(T4CMAREngineNIO.java:487)
at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:512)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.execute(AbstractLogMinerStreamingChangeEventSource.java:214)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.execute(AbstractLogMinerStreamingChangeEventSource.java:209)
at io.debezium.connector.oracle.logminer.AbstractLogMinerStreamingChangeEventSource.execute(AbstractLogMinerStreamingChangeEventSource.java:88)
at oracle.jdbc.driver.OracleStatement.prepareDefineBufferAndExecute(OracleStatement.java:1271)
at io.debezium.connector.oracle.logminer.buffered.BufferedLogMinerStreamingChangeEventSource.executeLogMiningStreaming(BufferedLogMinerStreamingChangeEventSource.java:156)
at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:115)
at oracle.jdbc.driver.OracleStatement.executeMaybeDescribe(OracleStatement.java:1149)
[2026-07-28 17:17:54,263] INFO [oracle-source-connector-prod-v26|task-0] Attempting to restart task. (io.debezium.connector.common.BaseSourceTask:442)
[2026-07-28 17:17:54,263] INFO [oracle-source-connector-prod-v26|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.oracle.OracleSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig:1929)
[2026-07-28 17:17:54,265] INFO [oracle-source-connector-prod-v26|task-0] Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy (io.debezium.config.CommonConnectorConfig:1617)
[2026-07-28 17:17:54,521] INFO [oracle-source-connector-prod-v26|task-0] Database Version: Oracle Database 19c Enterprise Edition Release 19.0.0.0.0 - Production
Version 19.30.0.0.0 (io.debezium.connector.oracle.OracleConnection:115)
[2026-07-28 17:17:54,554] INFO [oracle-source-connector-prod-v26|task-0] Oracle MAX_STRING_SIZE is STANDARD (io.debezium.connector.oracle.OracleConnection:852)
[2026-07-28 17:17:54,596] INFO [oracle-source-connector-prod-v26|task-0] KafkaSchemaHistory Consumer config: {key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=cg.pro.opusm-agic.t.datamart.sa.kafka-datamart.datasync-service, bootstrap.servers=lkc-zm00wy-pdr7zg.ap-southeast-1.aws.glb.confluent.cloud:9092, security.protocol=SASL_SSL, enable.auto.commit=false, sasl.mechanism=PLAIN, sasl.jaas.config=********, fetch.min.bytes=1, session.timeout.ms=10000, auto.offset.reset=earliest, ssl.endpoint.identification.algorithm=https, client.id=pro.opusm-agic-schemahistory} (io.debezium.storage.kafka.history.KafkaSchemaHistory:249)

Sijo Saji

unread,
Jul 28, 2026, 7:05:37 AM (6 days ago) Jul 28
to debezium

The above exception trace I shared is with older debezium version : 3.2.6 and older config 

Abhishek Chauhan

unread,
Jul 28, 2026, 11:16:31 AM (6 days ago) Jul 28
to debezium
Hi Chris,

Night jobs are running in parallel, and we are getting this error,
frequently. We have used "database.query.timeout.ms": 0, but with this
property it failed with this error
"Error: java.sql.SQLException: ORA-00310: archived log contains
sequence 166819; sequence 166813 required ORA-00334: archived log:
'/data/oradata/iccdb/redo01.log'"

Error occurred during Batch Jobs: ->>

<
{"time":"2026-07-28T13:44:13.444982908Z","stream":"stdout","_p":"P","log":"Caused
by: Error : 1013, Position : 275, 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#, CLIENT_ID, START_SCN, COMMIT_SCN,
START_TIMESTAMP, COMMIT_TIMESTAMP, SEQUENCE# FROM V$LOGMNR_CONTENTS
WHERE SCN > :1  AND SCN <= :2  AND (OPERATION_CODE IN
(1,2,3,6,7,27,34,36,255) OR (OPERATION_CODE = 5 AND INFO NOT LIKE
'INTERNAL DDL%')) AND (SEG_OWNER IS NULL OR UPPER(SEG_OWNER) IN
('UNKNOWN','CUSTOMER_I','OPUS_CORE','CUSTOMER')) AND (TABLE_NAME IS
NULL OR UPPER(SEG_OWNER || '.' || TABLE_NAME) IN (}
  Error Msg = ORA-01013: user requested cancel of current
operation","kubernetes":{"pod_name":"opus-gi-oraclesource-kafka-service-5d45bc68dc-d5fpc","namespace_name":"opusm","pod_id":"b49ceadb-f991-4d04-bd66-2183525afee9","host":"ip-100-80-41-213.ap-southeast-1.compute.internal","pod_ip":"1.240.29.207","container_name":"generic","docker_id":"b15eecce1168ff86e93048aaa8074df7064332801396a2a0c57945ae4a1ade42","container_hash":"992382782141.dkr.ecr.ap-southeast-1.amazonaws.com/opus-gi-oraclesource-kafka-service@sha256:5541015533c0a94368b4e6bed57f41ee9a59fd6adb8e3521dd028ce547c01aeb","container_image":"992382782141.dkr.ecr.ap-southeast-1.amazonaws.com/opus-gi-oraclesource-kafka-service:prod-dry-run-0.0.2"}}
{"time":"2026-07-28T13:44:13.444864335Z","stream":"stdout","_p":"F","log":"Caused
by: java.sql.SQLTimeoutException: ORA-01013: user requested cancel of
current operation","kubernetes":{"pod_name":"opus-gi-oraclesource-kafka-service-5d45bc68dc-d5fpc","namespace_name":"opusm","pod_id":"b49ceadb-f991-4d04-bd66-2183525afee9","host":"ip-100-80-41-213.ap-southeast-1.compute.internal","pod_ip":"1.240.29.207","container_name":"generic","docker_id":"b15eecce1168ff86e93048aaa8074df7064332801396a2a0c57945ae4a1ade42","container_hash":"992382782141.dkr.ecr.ap-southeast-1.amazonaws.com/opus-gi-oraclesource-kafka-service@sha256:5541015533c0a94368b4e6bed57f41ee9a59fd6adb8e3521dd028ce547c01aeb","container_image":"992382782141.dkr.ecr.ap-southeast-1.amazonaws.com/opus-gi-oraclesource-kafka-service:prod-dry-run-0.0.2"}}
{"time":"2026-07-28T13:44:13.182673001Z","stream":"stdout","_p":"P","log":"Caused
by: Error : 1013, Position : 275, 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#, CLIENT_ID, START_SCN, COMMIT_SCN,
START_TIMESTAMP, COMMIT_TIMESTAMP, SEQUENCE# FROM V$LOGMNR_CONTENTS
WHERE SCN > :1  AND SCN <= :2  AND (OPERATION_CODE IN
(1,2,3,6,7,27,34,36,255) OR (OPERATION_CODE = 5 AND INFO NOT LIKE
'INTERNAL DDL%')) AND (SEG_OWNER IS NULL OR UPPER(SEG_OWNER) IN
('UNKNOWN','CUSTOMER_I','OPUS_CORE','CUSTOMER')) AND (TABLE_NAME IS
NULL OR UPPER(SEG_OWNER || '.' || TABLE_NAME) IN (), Error Msg =
ORA-01013: user requested cancel of current
operation","kubernetes":{"pod_name":"opus-gi-oraclesource-kafka-service-5d45bc68dc-d5fpc","namespace_name":"opusm","pod_id":"b49ceadb-f991-4d04-bd66-2183525afee9","host":"ip-100-80-41-213.ap-southeast-1.compute.internal","pod_ip":"1.240.29.207","container_name":"generic","docker_id":"b15eecce1168ff86e93048aaa8074df7064332801396a2a0c57945ae4a1ade42","container_hash":"992382782141.dkr.ecr.ap-southeast-1.amazonaws.com/opus-gi-oraclesource-kafka-service@sha256:5541015533c0a94368b4e6bed57f41ee9a59fd6adb8e3521dd028ce547c01aeb","container_image":"992382782141.dkr.ecr.ap-southeast-1.amazonaws.com/opus-gi-oraclesource-kafka-service:prod-dry-run-0.0.2"}}
{"time":"2026-07-28T13:44:13.182542658Z","stream":"stdout","_p":"F","log":"java.sql.SQLTimeoutException:
ORA-01013: user requested cancel of current
operation","kubernetes":{"pod_name":"opus-gi-oraclesource-kafka-service-5d45bc68dc-d5fpc","namespace_name":"opusm","pod_id":"b49ceadb-f991-4d04-bd66-2183525afee9","host":"ip-100-80-41-213.ap-southeast-1.compute.internal","pod_ip":"1.240.29.207","container_name":"generic","docker_id":"b15eecce1168ff86e93048aaa8074df7064332801396a2a0c57945ae4a1ade42","container_hash":"992382782141.dkr.ecr.ap-southeast-1.amazonaws.com/opus-gi-oraclesource-kafka-service@sha256:5541015533c0a94368b4e6bed57f41ee9a59fd6adb8e3521dd028ce547c01aeb","container_image":"992382782141.dkr.ecr.ap-southeast-1.amazonaws.com/opus-gi-oraclesource-kafka-service:prod-dry-run-0.0.2"}}
{"time":"2026-07-28T13:44:13.182413355Z","stream":"stdout","_p":"P","log":"Caused
by: Error : 1013, Position : 275, 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#, CLIENT_ID, START_SCN, COMMIT_SCN,
START_TIMESTAMP, COMMIT_TIMESTAMP, SEQUENCE# FROM V$LOGMNR_CONTENTS
WHERE SCN > :1  AND SCN <= :2  AND (OPERATION_CODE IN
(1,2,3,6,7,27,34,36,255) OR (OPERATION_CODE = 5 AND INFO NOT LIKE
'INTERNAL DDL%')) AND (SEG_OWNER IS NULL OR UPPER(SEG_OWNER) IN
('UNKNOWN','CUSTOMER_I','OPUS_CORE','CUSTOMER')) AND (TABLE_NAME IS
NULL OR UPPER(SEG_OWNER || '.' || TABLE_NAME) IN (), Error Msg =
ORA-01013: user requested cancel of current
operation","kubernetes":{"pod_name":"opus-gi-oraclesource-kafka-service-5d45bc68dc-d5fpc","namespace_name":"opusm","pod_id":"b49ceadb-f991-4d04-bd66-2183525afee9","host":"ip-100-80-41-213.ap-southeast-1.compute.internal","pod_ip":"1.240.29.207","container_name":"generic","docker_id":"b15eecce1168ff86e93048aaa8074df7064332801396a2a0c57945ae4a1ade42","container_hash":"992382782141.dkr.ecr.ap-southeast-1.amazonaws.com/opus-gi-oraclesource-kafka-service@sha256:5541015533c0a94368b4e6bed57f41ee9a59fd6adb8e3521dd028ce547c01aeb","container_image":"992382782141.dkr.ecr.ap-southeast-1.amazonaws.com/opus-gi-oraclesource-kafka-service:prod-dry-run-0.0.2"}}
{"time":"2026-07-28T13:44:13.182226131Z","stream":"stdout","_p":"F","log":"java.sql.SQLTimeoutException:
ORA-01013: user requested cancel of current
operation","kubernetes":{"pod_name":"opus-gi-oraclesource-kafka-service-5d45bc68dc-d5fpc","namespace_name":"opusm","pod_id":"b49ceadb-f991-4d04-bd66-2183525afee9","host":"ip-100-80-41-213.ap-southeast-1.compute.internal","pod_ip":"1.240.29.207","container_name":"generic","docker_id":"b15eecce1168ff86e93048aaa8074df7064332801396a2a0c57945ae4a1ade42","container_hash":"992382782141.dkr.ecr.ap-southeast-1.amazonaws.com/opus-gi-oraclesource-kafka-service@sha256:5541015533c0a94368b4e6bed57f41ee9a59fd6adb8e3521dd028ce547c01aeb","container_image":"992382782141.dkr.ecr.ap-southeast-1.amazonaws.com/opus-gi-oraclesource-kafka-service:prod-dry-run-0.0.2"}}

Chris Cranford

unread,
Jul 28, 2026, 11:26:59 AM (6 days ago) Jul 28
to debe...@googlegroups.com
Hi -

So in your lower env, you're using `logminer_unbuffered` which is not the same as what you're using Production, nor has there been any meaningful changes in that adapter in 3.6.
You need to use `logminer` if you want the changes I spoke about with mining.

As to the exception in production, that's not Debezium-specific, that's that you have network connectivity or stability issues.

-cc

Chris Cranford

unread,
Jul 28, 2026, 11:38:59 AM (6 days ago) Jul 28
to debe...@googlegroups.com
Hi -

The `database.query.timeout.ms` only addresses "ORA-01013: user requested cancel of current operation". If you leave the property set to its default, and the LogMiner query runs for more than 10 minutes, you will get this error. If you then set the property, the query runs unbounded until it finishes; however, the query running too long with high IO contention can then lead to ORA-00310. This happens when logs roll too quickly during a mining operation or if a transaction is discarded and we later read a future part of that transaction that had a redo back-reference to an earlier redo entry that is no longer in the LogMiner cache.

Do you have the full logs from where this exception was thrown you can share?

Abhishek Chauhan

unread,
Jul 28, 2026, 12:59:33 PM (5 days ago) Jul 28
to debezium
Hi,

If I don't use database.query.timeout.ms, I'll get an ORA-01013 error during long-running overnight batch jobs. I'm also frequently encountering sequence missing errors. These are the two types of errors that occur most often during long-running batch jobs.

Caused by: java.sql.SQLTimeoutException: ORA-01013: user requested cancel of current operation
"Caused by: java.sql.SQLException: ORA-00310: archived log contains sequence 291845; sequence 291841 required"

log_1.txt

Chris Cranford

unread,
Jul 29, 2026, 9:30:49 AM (5 days ago) Jul 29
to debe...@googlegroups.com
Hi,

This is expected behavior when you don't set `database.query.timeout.ms`. Debezium automatically applies a 10 minute cap on any query to avoid a query blocking indefinitely. As a user, it's your choice to decide to disable this out of the box feature by setting `database.query.timeout.ms` to `0` or increasing the value of the cap accordingly to match your environment's expectations. Otherwise, after 10 minutes and if LogMiner hasn't returned the first row, ORA-01013 will be thrown.

Regarding the sequence related problem, I can't speak to without more detail, as I indicated in the other thread. If you could enable DEBUG logging for the following class, let the connector run until you experience the ORA-00310 failure, and then share the full log file with us, that would be the first step to identify potentially why, if its related to some log management bug in the connector.

    io.debezium.connector.oracle.LogFileCollector

Thanks,
-cc

Chris Cranford

unread,
Jul 29, 2026, 9:31:38 AM (5 days ago) Jul 29
to debe...@googlegroups.com
My apologies I hit send too quickly, I specified the wrong class name, it's

    io.debezium.connector.oracle.logminer.LogFileCollector

Regards,
-cc
Reply all
Reply to author
Forward
0 new messages