MySQL binlog parsing error

Skip to first unread message

Sagar Kapare

Dec 23, 2021, 3:18:32 PM12/23/21
to debezium
Hi All,

We are using debezium in embedded mode with 1.3.1.Final version of it. We are trying to get changes from mysql database, however seeing following error:

Any idea "CREATE OR REPLACE ALGORITHM"  supported in recent versions of debezium connector? or if any workaround for this?

Failed due to error: Error processing binlog event org.apache.kafka.connect.errors.ConnectException: no viable alternative at input 'CREATE OR REPLACE ALGORITHM=UNDEFINED DEFINER=`root`@`` SQL SECURITY DEFINER VIEW `sample_39016567_194` AS SELECT\n,\n sample.title,\n sample.domainId,\n CAST( AS CHAR charset utf8mb4) AS srcProductId,\n sample.recommendProductId,\n CAST(product.category_id AS CHAR charset utf8mb4) AS categoryId FROM (\n SELECT\n,\n block.title,\n block.domainId,\n CAST(results.srcProductId AS CHAR charset utf8mb4) AS srcProductId,\n CAST(results.recommendProductId AS CHAR charset utf8mb4) AS recommendProductId,\n CAST(results.objectId AS CHAR charset utf8mb4) AS objectId,\n results.objectType\n FROM (\n SELECT\n *\n FROM\n reco_shared.sample\n WHERE\n domainId = '39016567'\n AND disable = 0 ) AS block\n LEFT JOIN (\n SELECT block_result.*,\n sample.config -> "$.algoGroup.objectType" as objectType \n FROM (SELECT\n block_result.domainId,\n block_result.algoHash,\n NULL as srcProductId,\n CAST(recommend_json.product_id AS CHAR charset utf8mb4) as recommendProductId,\n block_result.objectId as objectId\n FROM (\n SELECT\n domainId,\n algoHash,\n MAX(version) AS latestVersion\n FROM\n reco_shared.block_result\n WHERE\n domainId = '39016567'\n GROUP BY\n domainId,\n algoHash ) versionTable\n INNER JOIN\n reco_shared.block_result\n ON\n block_result.domainId = versionTable.domainId\n AND block_result.algoHash = versionTable.algoHash\n AND block_result.version = versionTable.latestVersion,\n JSON_TABLE(' at io.debezium.connector.mysql.AbstractReader.wrap( at io.debezium.connector.mysql.AbstractReader.failed( at io.debezium.connector.mysql.BinlogReader.handleEvent(

Thanks and Regards,

Sagar Kapare

Dec 27, 2021, 11:44:52 AM12/27/21
to debezium
We are using MySQL 8.0.18 version. Any idea about this error and any workaround?

Chris Cranford

Jan 2, 2022, 7:22:02 AMJan 2
to, Sagar Kapare
Hi Sagar

I would suggest you give 1.8.0.Final a try and see if the error still exists.  Version 1.3.1 is quite old and is no longer being maintained.

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
To view this discussion on the web visit

Reply all
Reply to author
0 new messages