MySQL binlog parsing error

65 views
Skip to first unread message

Sagar Kapare

unread,
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 sample.id,\n sample.title,\n sample.domainId,\n CAST(product.id AS CHAR charset utf8mb4) AS srcProductId,\n sample.recommendProductId,\n CAST(product.category_id AS CHAR charset utf8mb4) AS categoryId FROM (\n SELECT\n block.id,\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(AbstractReader.java:230) at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:207) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:604)

Thanks and Regards,
Sagar

Sagar Kapare

unread,
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

unread,
Jan 2, 2022, 7:22:02 AMJan 2
to debe...@googlegroups.com, 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.

Chris
--
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 on the web visit https://groups.google.com/d/msgid/debezium/efd2a7e2-d51a-4772-9180-1cd142adcf72n%40googlegroups.com.

Reply all
Reply to author
Forward
0 new messages