[2022-01-19 06:53:07,244] INFO Requested thread factory for connector OracleConnector, id = idstore named = db-history-config-check (io.debezium.util.Threads:270) [2022-01-19 06:53:07,252] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection:965) [2022-01-19 06:53:07,253] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection:965) [2022-01-19 06:53:07,255] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection:965) [2022-01-19 06:53:07,255] ERROR Mining session stopped due to the {} (io.debezium.connector.oracle.logminer.LogMinerHelper:118) java.lang.IllegalArgumentException: Unsupported column type: rowid at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:264) at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:83) at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.enterColumn_definition(ColumnDefinitionParserListener.java:53) at io.debezium.connector.oracle.antlr.listener.CreateTableParserListener.lambda$enterColumn_definition$1(CreateTableParserListener.java:81) at io.debezium.connector.oracle.antlr.OracleDdlParser.runIfNotNull(OracleDdlParser.java:158) at io.debezium.connector.oracle.antlr.listener.CreateTableParserListener.enterColumn_definition(CreateTableParserListener.java:76) at io.debezium.ddl.parser.oracle.generated.PlSqlParser$Column_definitionContext.enterRule(PlSqlParser.java) at io.debezium.antlr.ProxyParseTreeListenerUtil.delegateEnterRule(ProxyParseTreeListenerUtil.java:46) at io.debezium.connector.oracle.antlr.listener.OracleDdlParserListener.enterEveryRule(OracleDdlParserListener.java:46) at org.antlr.v4.runtime.tree.ParseTreeWalker.enterRule(ParseTreeWalker.java:41) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:25) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:87) at io.debezium.connector.oracle.antlr.OracleDdlParser.parse(OracleDdlParser.java:63) at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:84) at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:307) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:257) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:326) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:175) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:150) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.process(MemoryLogMinerEventProcessor.java:116) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:148) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:56) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:165) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) [2022-01-19 06:53:07,255] ERROR Producer failure (io.debezium.pipeline.ErrorHandler:31) java.lang.IllegalArgumentException: Unsupported column type: rowid at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:264) at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:83) at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.enterColumn_definition(ColumnDefinitionParserListener.java:53) at io.debezium.connector.oracle.antlr.listener.CreateTableParserListener.lambda$enterColumn_definition$1(CreateTableParserListener.java:81) at io.debezium.connector.oracle.antlr.OracleDdlParser.runIfNotNull(OracleDdlParser.java:158) at io.debezium.connector.oracle.antlr.listener.CreateTableParserListener.enterColumn_definition(CreateTableParserListener.java:76) at io.debezium.ddl.parser.oracle.generated.PlSqlParser$Column_definitionContext.enterRule(PlSqlParser.java) at io.debezium.antlr.ProxyParseTreeListenerUtil.delegateEnterRule(ProxyParseTreeListenerUtil.java:46) at io.debezium.connector.oracle.antlr.listener.OracleDdlParserListener.enterEveryRule(OracleDdlParserListener.java:46) at org.antlr.v4.runtime.tree.ParseTreeWalker.enterRule(ParseTreeWalker.java:41) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:25) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:87) at io.debezium.connector.oracle.antlr.OracleDdlParser.parse(OracleDdlParser.java:63) at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:84) at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:307) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:257) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:326) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:175) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:150) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.process(MemoryLogMinerEventProcessor.java:116) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:148) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:56) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:165) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) [2022-01-19 06:53:07,256] INFO startScn=18052523522699, endScn=18052523542699 (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:164) [2022-01-19 06:53:07,256] INFO Streaming metrics dump: OracleStreamingChangeEventSourceMetrics{currentScn=18052528545807, oldestScn=18052523522700, committedScn=18052523534578, offsetScn=18052523522699, logMinerQueryCount=1, totalProcessedRows=0, totalCapturedDmlCount=0, totalDurationOfFetchingQuery=PT5.302S, lastCapturedDmlCount=0, lastDurationOfFetchingQuery=PT5.302S, maxCapturedDmlCount=0, maxDurationOfFetchingQuery=PT5.302S, totalBatchProcessingDuration=PT0S, lastBatchProcessingDuration=PT0S, maxBatchProcessingDuration=PT0S, maxBatchProcessingThroughput=0, currentLogFileName=[Ljava.lang.String;@218af79e, minLogFilesMined=0, maxLogFilesMined=2, redoLogStatus=[Ljava.lang.String;@b4714f4, switchCounter=105, batchSize=30000, millisecondToSleepBetweenMiningQuery=180, hoursToKeepTransaction=1, networkConnectionProblemsCounter0, batchSizeDefault=20000, batchSizeMin=10000, batchSizeMax=200000, sleepTimeDefault=200, sleepTimeMin=40, sleepTimeMax=1000, sleepTimeIncrement=20, totalParseTime=PT0.006S, totalStartLogMiningSessionDuration=PT16.523S, lastStartLogMiningSessionDuration=PT16.523S, maxStartLogMiningSessionDuration=PT16.523S, totalProcessTime=PT0S, minBatchProcessTime=PT0S, maxBatchProcessTime=PT0S, totalResultSetNextTime=PT0.001S, lagFromTheSource=DurationPT5H17M0.137S, maxLagFromTheSourceDuration=PT5H17M39.627S, minLagFromTheSourceDuration=PT0S, lastCommitDuration=PT0S, maxCommitDuration=PT0.006S, activeTransactions=5, rolledBackTransactions=2, committedTransactions=423, abandonedTransactionIds=[], rolledbackTransactionIds=[a603080079280000, a1130e008b2a0000], registeredDmlCount=1649, committedDmlCount=25, errorCount=1, warningCount=0, scnFreezeCount=0, unparsableDdlCount=0, miningSessionUserGlobalAreaMemory=0, miningSessionUserGlobalAreaMaxMemory=0, miningSessionProcessGlobalAreaMemory=0, miningSessionProcessGlobalAreaMaxMemory=0} (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:165) [2022-01-19 06:53:07,256] INFO Offsets: OracleOffsetContext [scn=18052523522699] (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:166) [2022-01-19 06:53:07,256] INFO Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:166) [2022-01-19 06:53:07,256] INFO Connected metrics set to 'false' (io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics:70) [2022-01-19 06:53:07,463] INFO 50 records sent during previous 00:00:57.763, last recorded offset: {commit_scn=18052523527486, transaction_id=c61b0500fe240000, transaction_data_collection_order_IDBTSDBHA.WEBEX.COM.IDENTITYDB.USERS=4, transaction_data_collection_order_IDBTSDBHA.WEBEX.COM.IDENTITYDB.CHANGE_NUMBERS=4, transaction_data_collection_order_IDBTSDBHA.WEBEX.COM.IDENTITYDB.USER_MULTIVALUED_ATTRIBUTES=88, transaction_data_collection_order_IDBTSDBHA.WEBEX.COM.IDENTITYDB.ACCOUNT_PASSWORDS=4, scn=18052523522699} (io.debezium.connector.common.BaseSourceTask:185) [2022-01-19 06:53:07,463] DEBUG dispatch USERS record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USERS:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:08,679] DEBUG dispatch ACCOUNT_PASSWORDS record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.ACCOUNT_PASSWORDS:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:08,888] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,099] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,100] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,100] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,100] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,100] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,101] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,101] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,101] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,101] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,102] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,102] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,102] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,102] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,102] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,103] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,103] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,103] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,103] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,104] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,104] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,104] DEBUG dispatch USER_MULTIVALUED_ATTRIBUTES record: a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000 to idstore.LOGMINER.USER_MULTIVALUED_ATTRIBUTES:77 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:383) [2022-01-19 06:53:09,104] DEBUG ChangeNumbers record: User, a7ec2a50-264d-4fe8-bc59-ec74b4cd971e, c61b0500fe240000, 1012523292 (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:347) [2022-01-19 06:53:09,314] DEBUG TransactionMetadata c61b0500fe240000: Struct{status=END,id=c61b0500fe240000,event_count=100,data_collections=[Struct{data_collection=IDBTSDBHA.WEBEX.COM.IDENTITYDB.ACCOUNT_PASSWORDS,event_count=4}, Struct{data_collection=IDBTSDBHA.WEBEX.COM.IDENTITYDB.USER_MULTIVALUED_ATTRIBUTES,event_count=88}, Struct{data_collection=IDBTSDBHA.WEBEX.COM.IDENTITYDB.CHANGE_NUMBERS,event_count=4}, Struct{data_collection=IDBTSDBHA.WEBEX.COM.IDENTITYDB.USERS,event_count=4}]} (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:431) [2022-01-19 06:53:09,523] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-01-19 06:53:09,524] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} flushing 34 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-01-19 06:53:09,731] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-01-19 06:53:09,731] ERROR Invalid call to OffsetStorageWriter flush() while already flushing, the framework should not allow this (org.apache.kafka.connect.storage.OffsetStorageWriter:109) [2022-01-19 06:53:09,731] ERROR WorkerSourceTask{id=debezium-BTS-sjc-0110-0} Unhandled exception when committing: (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:121) org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:111) at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:490) at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:113) at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:47) at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:86) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) [2022-01-19 06:53:09,736] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} Finished commitOffsets successfully in 212 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:574) [2022-01-19 06:53:09,736] ERROR WorkerSourceTask{id=debezium-BTS-sjc-0110-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:187) org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:161) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:56) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:165) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: java.lang.IllegalArgumentException: Unsupported column type: rowid at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:264) at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.resolveColumnDataType(ColumnDefinitionParserListener.java:83) at io.debezium.connector.oracle.antlr.listener.ColumnDefinitionParserListener.enterColumn_definition(ColumnDefinitionParserListener.java:53) at io.debezium.connector.oracle.antlr.listener.CreateTableParserListener.lambda$enterColumn_definition$1(CreateTableParserListener.java:81) at io.debezium.connector.oracle.antlr.OracleDdlParser.runIfNotNull(OracleDdlParser.java:158) at io.debezium.connector.oracle.antlr.listener.CreateTableParserListener.enterColumn_definition(CreateTableParserListener.java:76) at io.debezium.ddl.parser.oracle.generated.PlSqlParser$Column_definitionContext.enterRule(PlSqlParser.java) at io.debezium.antlr.ProxyParseTreeListenerUtil.delegateEnterRule(ProxyParseTreeListenerUtil.java:46) at io.debezium.connector.oracle.antlr.listener.OracleDdlParserListener.enterEveryRule(OracleDdlParserListener.java:46) at org.antlr.v4.runtime.tree.ParseTreeWalker.enterRule(ParseTreeWalker.java:41) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:25) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28) at org.antlr.v4.runtime.tree.ParseTreeWalker.walk(ParseTreeWalker.java:28) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:87) at io.debezium.connector.oracle.antlr.OracleDdlParser.parse(OracleDdlParser.java:63) at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:84) at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:307) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleSchemaChange(AbstractLogMinerEventProcessor.java:257) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.handleSchemaChange(MemoryLogMinerEventProcessor.java:326) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:175) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:150) at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.process(MemoryLogMinerEventProcessor.java:116) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:148) ... 8 more [2022-01-19 06:53:09,737] ERROR WorkerSourceTask{id=debezium-BTS-sjc-0110-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:188) [2022-01-19 06:53:09,737] INFO Stopping down connector (io.debezium.connector.common.BaseSourceTask:241) [2022-01-19 06:53:09,745] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection:965) [2022-01-19 06:53:09,745] INFO [Producer clientId=idstore-dbhistory] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1189) [2022-01-19 06:53:09,746] INFO [Producer clientId=connector-producer-debezium-BTS-sjc-0110-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1189) [2022-01-19 06:53:09,748] INFO Close ColumnBasedPartitioner (com.cisco.identity.debezium.kafka.connect.transforms.ColumnBasedPartitioner:148) [2022-01-19 06:53:12,732] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-01-19 06:53:12,732] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-01-19 06:53:15,732] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-01-19 06:53:15,733] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-01-19 06:53:18,733] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-01-19 06:53:18,733] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-01-19 06:53:21,734] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-01-19 06:53:21,734] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-01-19 06:53:24,734] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-01-19 06:53:24,734] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-01-19 06:53:27,735] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-01-19 06:53:27,735] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495) [2022-01-19 06:53:30,735] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:478) [2022-01-19 06:53:30,735] INFO WorkerSourceTask{id=debezium-BTS-sjc-0110-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:495)