2022-03-10 14:00:16,367 ERROR [io.deb.con.mys.MySqlStreamingChangeEventSource] (blc-localhost:3306) Error during binlog processing. Last offset stored = {transaction_id=null, ts_sec=1646917216, file=mariadb-bin.000100, pos=38175559, server_id=1, event=1}, binlog reader near position = mariadb-bin.000100/38175559
2022-03-10 14:00:16,367 ERROR [io.deb.pip.ErrorHandler] (blc-localhost:3306) Producer failure: io.debezium.DebeziumException: Error processing binlog event
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:369)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$25(MySqlStreamingChangeEventSource.java:860)
        at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1125)
        at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:973)
        at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:599)
        at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:857)
        at java.base/java.lang.Thread.run(Thread.java:831)
Caused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'create index IF NOT EXISTS IDX_DT_LAST_UPDATE on patient(DT_LAST_UPDATE)'
no viable alternative at input 'create index IF'
        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.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1223)
        at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:945)
        at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:73)
        at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:45)
        at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:82)
        at io.debezium.connector.mysql.MySqlDatabaseSchema.parseDdl(MySqlDatabaseSchema.java:223)
        at io.debezium.connector.mysql.MySqlDatabaseSchema.parseStreamingDdl(MySqlDatabaseSchema.java:209)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleQueryEvent(MySqlStreamingChangeEventSource.java:576)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$14(MySqlStreamingChangeEventSource.java:832)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:349)
        ... 6 more
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.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1021)
        ... 15 more

2022-03-10 14:00:16,372 INFO  [io.deb.con.mys.MySqlStreamingChangeEventSource] (blc-localhost:3306) Error processing binlog event, and propagating to Kafka Connect so it stops this connector. Future binlog events read before connector is shutdown will be ignored.
2022-03-10 14:00:16,493 INFO  [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) 9 records sent during previous 00:00:27.542, last recorded offset: {transaction_id=null, ts_sec=1646917216, file=mariadb-bin.000100, pos=38175559, server_id=1}
2022-03-10 14:00:16,503 INFO  [io.deb.ser.kin.KinesisChangeConsumer] (pool-7-thread-1) I got '431' in total
2022-03-10 14:00:16,508 INFO  [io.deb.ser.kin.KinesisChangeConsumer] (pool-7-thread-1) I got '432' in total
2022-03-10 14:00:16,515 INFO  [io.deb.ser.kin.KinesisChangeConsumer] (pool-7-thread-1) I got '433' in total
2022-03-10 14:00:16,520 INFO  [io.deb.ser.kin.KinesisChangeConsumer] (pool-7-thread-1) I got '434' in total
2022-03-10 14:00:16,525 INFO  [io.deb.ser.kin.KinesisChangeConsumer] (pool-7-thread-1) I got '435' in total
2022-03-10 14:00:16,529 INFO  [io.deb.ser.kin.KinesisChangeConsumer] (pool-7-thread-1) I got '436' in total
2022-03-10 14:00:16,534 INFO  [io.deb.ser.kin.KinesisChangeConsumer] (pool-7-thread-1) I got '437' in total
2022-03-10 14:00:16,539 INFO  [io.deb.ser.kin.KinesisChangeConsumer] (pool-7-thread-1) I got '438' in total
2022-03-10 14:00:16,545 INFO  [io.deb.ser.kin.KinesisChangeConsumer] (pool-7-thread-1) I got '439' in total
2022-03-10 14:00:16,545 INFO  [io.deb.emb.EmbeddedEngine] (pool-7-thread-1) Stopping the task and engine
2022-03-10 14:00:16,545 INFO  [io.deb.con.com.BaseSourceTask] (pool-7-thread-1) Stopping down connector
2022-03-10 14:00:16,651 INFO  [io.deb.pip.ChangeEventSourceCoordinator] (debezium-mysqlconnector-mariaDB-change-event-source-coordinator) Finished streaming
2022-03-10 14:00:16,652 INFO  [io.deb.con.mys.MySqlStreamingChangeEventSource] (blc-localhost:3306) Stopped reading binlog after 0 events, last recorded offset: {transaction_id=null, ts_sec=1646917216, file=mariadb-bin.000100, pos=38177110, server_id=1, event=1}
2022-03-10 14:00:16,658 INFO  [io.deb.jdb.JdbcConnection] (pool-9-thread-1) Connection gracefully closed
2022-03-10 14:00:16,660 INFO  [org.apa.kaf.con.sto.FileOffsetBackingStore] (pool-7-thread-1) Stopped FileOffsetBackingStore
2022-03-10 14:00:16,662 INFO  [io.deb.ser.ConnectorLifecycle] (pool-7-thread-1) Connector completed: success = 'false', message = 'Error while trying to run connector class 'io.debezium.connector.mysql.MySqlConnector'', error = '{}': 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.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:369)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$25(MySqlStreamingChangeEventSource.java:860)
        at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1125)
        at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:973)
        at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:599)
        at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:857)
        at java.base/java.lang.Thread.run(Thread.java:831)
Caused by: io.debezium.DebeziumException: Error processing binlog event
        ... 7 more
Caused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'create index IF NOT EXISTS IDX_DT_LAST_UPDATE on patient(DT_LAST_UPDATE)'
no viable alternative at input 'create index IF'
        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.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1223)
        at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:945)
        at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:73)
        at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:45)
        at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:82)
        at io.debezium.connector.mysql.MySqlDatabaseSchema.parseDdl(MySqlDatabaseSchema.java:223)
        at io.debezium.connector.mysql.MySqlDatabaseSchema.parseStreamingDdl(MySqlDatabaseSchema.java:209)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleQueryEvent(MySqlStreamingChangeEventSource.java:576)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$14(MySqlStreamingChangeEventSource.java:832)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:349)
        ... 6 more
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.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1021)
        ... 15 more

2022-03-10 14:00:16,701 INFO  [io.deb.ser.DebeziumServer] (main) Received request to stop the engine
2022-03-10 14:00:16,701 INFO  [io.deb.emb.EmbeddedEngine] (main) Stopping the embedded engine
2022-03-10 14:00:16,756 INFO  [io.quarkus] (main) debezium-server-dist stopped in 0.092s