MySQL binlog parsing error

[Sagar Kapare]

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]

We are using MySQL 8.0.18 version. Any idea about this error and any workaround?

[Chris Cranford]

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.