[2021-07-14 10:28:49,029] INFO DDL: transactionId=03002000c5093f00, SCN=10360970425182, table_name=ESHP_AUCTION_FILE_HISTORY, segOwner=ESHOP, operationCode=5, offsetSCN=10360970421492,  commitOffsetSCN=10360970422971, REDO_SQL: create table eshp_auction_file_history (
                 history_id number not null,
                 history_date timestamp not null,
                 auction_id number not null,
                 changed_by varchar(4000),
                 type varchar(4000) not null,
                 constraint pk_eshp_auction_file_history primary key (history_id) using index (create unique index idx_eshp_auction_file_history_id on eshp_auction_file_history(history_id)),
                 constraint fk_eshp_auc_file_history_auction foreign key (auction_id) references eshp_auction(auction_id) on delete cascade
            ); (io.debezium.connector.oracle.logminer.LogMinerQueryResultProcessor:164)
[2021-07-14 10:28:49,030] INFO KafkaDatabaseHistory Consumer config: {enable.auto.commit=false, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=eaistdev-dbhistory, auto.offset.reset=earliest, session.timeout.ms=10000, bootstrap.servers=10.241.25.71:8091,10.241.25.71:8092,10.241.25.72:8091,10.241.25.72:8092, client.id=eaistdev-dbhistory, key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, fetch.min.bytes=1} (io.debezium.relational.history.KafkaDatabaseHistory:215)
[2021-07-14 10:28:49,030] INFO KafkaDatabaseHistory Producer config: {bootstrap.servers=10.241.25.71:8091,10.241.25.71:8092,10.241.25.72:8091,10.241.25.72:8092, value.serializer=org.apache.kafka.common.serialization.StringSerializer, buffer.memory=1048576, retries=1, key.serializer=org.apache.kafka.common.serialization.StringSerializer, client.id=eaistdev-dbhistory, linger.ms=0, batch.size=32768, max.block.ms=10000, acks=1} (io.debezium.relational.history.KafkaDatabaseHistory:216)
[2021-07-14 10:28:49,030] INFO Requested thread factory for connector OracleConnector, id = eaistdev named = db-history-config-check (io.debezium.util.Threads:270)
[2021-07-14 10:28:49,160] ERROR Mining session stopped due to the {} (io.debezium.connector.oracle.logminer.LogMinerHelper:506)
io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'create table eshp_auction_file_history (
                 history_id number not null,
                 history_date timestamp not null,
                 auction_id number not null,
                 changed_by varchar(4000),
                 type varchar(4000) not null,
                 constraint pk_eshp_auction_file_history primary key (history_id) using index (create unique index idx_eshp_auction_file_history_id on eshp_auction_file_history(history_id)),
                 constraint fk_eshp_auc_file_history_auction foreign key (auction_id) references eshp_auction(auction_id) on delete cascade
            );'
no viable alternative at input 'eshp_auction_file_history(history_id))'
        at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43)
        at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41)
        at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544)
        at org.antlr.v4.runtime.DefaultErrorStrategy.reportNoViableAlternative(DefaultErrorStrategy.java:310)
        at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:136)
        at io.debezium.ddl.parser.oracle.generated.PlSqlParser.create_index(PlSqlParser.java:15121)
        at io.debezium.ddl.parser.oracle.generated.PlSqlParser.using_index_clause(PlSqlParser.java)
        at io.debezium.ddl.parser.oracle.generated.PlSqlParser.constraint_state(PlSqlParser.java:41615)
        at io.debezium.ddl.parser.oracle.generated.PlSqlParser.out_of_line_constraint(PlSqlParser.java:41434)
        at io.debezium.ddl.parser.oracle.generated.PlSqlParser.relational_property(PlSqlParser.java:50999)
        at io.debezium.ddl.parser.oracle.generated.PlSqlParser.relational_table(PlSqlParser.java:50746)
        at io.debezium.ddl.parser.oracle.generated.PlSqlParser.create_table(PlSqlParser.java:49072)
        at io.debezium.ddl.parser.oracle.generated.PlSqlParser.unit_statement(PlSqlParser.java:2421)
        at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:68)
        at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:32)
        at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:82)
        at io.debezium.connector.oracle.antlr.OracleDdlParser.parse(OracleDdlParser.java:63)
        at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:81)
        at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:297)
        at io.debezium.connector.oracle.logminer.LogMinerQueryResultProcessor.processResult(LogMinerQueryResultProcessor.java:169)
        at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:184)
        at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:63)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:159)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:122)
        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: org.antlr.v4.runtime.NoViableAltException
        at org.antlr.v4.runtime.atn.ParserATNSimulator.noViableAlt(ParserATNSimulator.java:2026)
        at org.antlr.v4.runtime.atn.ParserATNSimulator.execATN(ParserATNSimulator.java:467)
        at org.antlr.v4.runtime.atn.ParserATNSimulator.adaptivePredict(ParserATNSimulator.java:393)
        at io.debezium.ddl.parser.oracle.generated.PlSqlParser.create_index(PlSqlParser.java:15085)
        ... 23 more
io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'create table eshp_auction_file_history (
                 history_id number not null,
                 history_date timestamp not null,
                 auction_id number not null,
                 changed_by varchar(4000),
                 type varchar(4000) not null,
                 constraint pk_eshp_auction_file_history primary key (history_id) using index (create unique index idx_eshp_auction_file_history_id on eshp_auction_file_history(history_id)),
                 constraint fk_eshp_auc_file_history_auction foreign key (auction_id) references eshp_auction(auction_id) on delete cascade
            );'
mismatched input ',' expecting {'AS', ';'}
        at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43)
        at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41)
        at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544)
        at org.antlr.v4.runtime.DefaultErrorStrategy.reportInputMismatch(DefaultErrorStrategy.java:327)
        at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:139)
        at io.debezium.ddl.parser.oracle.generated.PlSqlParser.create_table(PlSqlParser.java:49106)
        at io.debezium.ddl.parser.oracle.generated.PlSqlParser.unit_statement(PlSqlParser.java:2421)
        at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:68)
        at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:32)
        at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:82)
        at io.debezium.connector.oracle.antlr.OracleDdlParser.parse(OracleDdlParser.java:63)
        at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:81)
        at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:297)
        at io.debezium.connector.oracle.logminer.LogMinerQueryResultProcessor.processResult(LogMinerQueryResultProcessor.java:169)
        at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:184)
        at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:63)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:159)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:122)
        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: org.antlr.v4.runtime.InputMismatchException
        at org.antlr.v4.runtime.DefaultErrorStrategy.sync(DefaultErrorStrategy.java:270)
        at io.debezium.ddl.parser.oracle.generated.PlSqlParser.create_table(PlSqlParser.java:49089)
        ... 17 more

{'name': 'oracle_logminer_140721-1341', 'config': {'connector.class': 'io.debezium.connector.oracle.OracleConnector', 'tasks.max': '1', 'snapshot.mode': 'schema_only', 'snapshot.delay.ms': '10000', 'provide.transaction.metadata': 'true', 'decimal.handling.mode': 'string', 'sanitize.field.names': 'true', 'event.processing.failure.handling.mode': 'skip', 'database.history.kafka.bootstrap.servers': '...', 'database.history.kafka.topic': 'history_oracle_logminer_140721-1341', 'snapshot.locking.mode': 'none', 'log.mining.transaction.retention.hours': '1', 'table.include.list': 'ABCD_SHARD_1_3.D_LOT_VERSION,ABCD_SHARD_1_3.D_LOT_ENTITY,ABCD_SHARD_1_3.D_LOT_STATUS_HISTORY,ABCD_SHARD_1_3.D_PROCEDURE_LOT_ENTRY,ABCD_SHARD_1_3.D_LOT_LOT_ENTRY,ABCD_SHARD_1_3.D_PROCEDURE_VERSION,ABCD_SHARD_1_3.D_PROCEDURE_ENTITY,ABCD_SHARD_1_3.D_PLAN_SCHEDULE_LOT_ENTRY,ABCD_SHARD_1_3.D_PLAN_SCHEDULE_VERSION,ABCD_SHARD_1_3.D_PLAN_SCHEDULE_ENTITY,ABCD_SHARD_1_3.D_BID,ABCD_SHARD_1_3.D_EA_PARTICIPANT,ABCD_SHARD_1_3.D_LOT_LOTNUM_ENTRY,ABCD_SHARD_1_3.D_PROCEDURE_STATUS_HISTORY,ABCD_SHARD_1_3.D_OOS_EXCHANGE_PROTOCOL,ABCD_SHARD_1_3.D_PROCEDURE_DATE,ABCD_SHARD_1_3.D_OOS_FTP_PROTOCOL,ABCD_SHARD_1_3.D_COMMISSION_SESSION,ABCD_SHARD_1_3.D_LOT_NMC,ABCD_SHARD_1_3.D_LOT_NMC_EXAMINATION,ABCD_NSI.N_SPGZ,ABCD_NSI.N_CHARACTERISTIC_SPGZ,ABCD_NSI.N_SPGZ_CHARACTERISTIC_SPGZ,ABCD_NSI.N_CHARACTERISTIC_SPGZ_ENUM,ABCD_NSI.N_KPGZ,ABCD_NSI.N_CHARACTERISTIC_KPGZ,ABCD_NSI.N_KPGZ_CHARACTERISTIC_KPGZ,ABCD_NSI.N_CHARACTERISTIC_KPGZ_ENUM,ABCD_NSI.N_KPGZ_CONTRACT_TEMPLATE,ABCD_NSI.N_KPGZ_TECH_TASK,ABCD_NSI.N_CHARACTERISTIC,ABCD_NSI.N_OKEI_SPGZ', 'database.server.name': 'ABCDdev', 'database.hostname': '...', 'rac.node': '', 'database.port': '1521', 'database.user': 'xstrm', 'database.password': 'xstrm', 'database.dbname': 'ABCDdev'}}