{"id":46910,"date":"2023-07-27T08:25:03","date_gmt":"2023-08-28T13:37:36","guid":{"rendered":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%b0%9d%e8%af%95%e5%9c%a8openshift%e4%b8%8a%e4%bd%bf%e7%94%a8debezium%e8%bf%9e%e6%8e%a5%e5%99%a8%e5%b0%86%e9%85%8d%e7%bd%ae%e7%9a%84confluent-platform%e5%92%8cmysql%e8%bf%9b%e8%a1%8c%e9%9b%86\/"},"modified":"2024-04-30T15:36:10","modified_gmt":"2024-04-30T07:36:10","slug":"%e5%b0%9d%e8%af%95%e5%9c%a8openshift%e4%b8%8a%e4%bd%bf%e7%94%a8debezium%e8%bf%9e%e6%8e%a5%e5%99%a8%e5%b0%86%e9%85%8d%e7%bd%ae%e7%9a%84confluent-platform%e5%92%8cmysql%e8%bf%9b%e8%a1%8c%e9%9b%86","status":"publish","type":"post","link":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%b0%9d%e8%af%95%e5%9c%a8openshift%e4%b8%8a%e4%bd%bf%e7%94%a8debezium%e8%bf%9e%e6%8e%a5%e5%99%a8%e5%b0%86%e9%85%8d%e7%bd%ae%e7%9a%84confluent-platform%e5%92%8cmysql%e8%bf%9b%e8%a1%8c%e9%9b%86\/","title":{"rendered":"\u5c1d\u8bd5\u5728OpenShift\u4e0a\u4f7f\u7528Debezium\u8fde\u63a5\u5668\u5c06\u914d\u7f6e\u7684Confluent Platform\u548cMySQL\u8fdb\u884c\u96c6\u6210"},"content":{"rendered":"<h1>\u9996\u5148<\/h1>\n<p>\u8ba9\u6211\u4eec\u4f7f\u7528Debezium\u7684MySQL Source Connector\u5728OpenShift\u4e0a\u914d\u7f6e\u7684Confluent Platform\u548cMySQL\u4e4b\u95f4\u8fdb\u884c\u6570\u636e\u534f\u4f5c\u3002<\/p>\n<h1>\u53ea\u9700\u8981\u4e00\u79cd\u9009\u62e9\u7684\u8bdd\uff0c\u53ef\u4ee5\u8fd9\u6837\u91ca\u4e49\uff1a&#8221;\u6761\u4ef6&#8221;<\/h1>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">IBM Cloud\u00ae Virtual Private Cloud(VPC)\u306bOpenShift Container Platform(OCP) 4.7\u3092\u69cb\u6210<\/ul>\n<\/li>\n<\/ul>\n<p>&nbsp;<\/p>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">OCP\u4e0a\u306bConfluent Platform 6.0.0\u3092\u69cb\u6210\uff08Confluent Operator 1.7.0\u3092\u5229\u7528\uff09<\/ul>\n<\/li>\n<\/ul>\n<p>&nbsp;<\/p>\n<ul class=\"post-ul\">OCP\u4e0a\u306bMySQL 8.0\u3092\u69cb\u6210<\/ul>\n<h1>\u8bf7\u63d0\u4f9b\u66f4\u591a\u7684\u4e0a\u4e0b\u6587\u6216\u8005\u5177\u4f53\u5185\u5bb9\uff0c\u4ee5\u4fbf\u6211\u80fd\u591f\u6b63\u786e\u5730\u4e3a\u60a8\u63d0\u4f9b\u7ffb\u8bd1\u3002<\/h1>\n<p>Debezium MySQL \u8fde\u63a5\u5668\u7684\u914d\u7f6e\u793a\u4f8b<br \/>\nDebezium MySQL \u6e90\u8fde\u63a5\u5668\u914d\u7f6e\u5c5e\u6027 &#8211; \u6570\u636e\u5e93\u5386\u53f2\u53c2\u6570<br \/>\n\u5c06 MySQL \u8868\u7684\u66f4\u65b0\u4fe1\u606f\u5728 Kafka \u4e0a\u901a\u8fc7 ksql \u8fdb\u884c\u5904\u7406\u7684\u793a\u4f8b<\/p>\n<h1>\u786e\u8ba4\u6784\u6210<\/h1>\n<p>\u786e\u4fddConfluent Platform\u6210\u529f\u542f\u52a8\u3002<\/p>\n<pre class=\"post-pre\"><code>&gt;oc get all -n confluent-namespace\r\nI0912 23:39:24.059883   37555 request.go:621] Throttling request took 1.090165589s, request: GET:https:\/\/c100-e.jp-tok.containers.cloud.ibm.com:31330\/apis\/packages.operators.coreos.com\/v1?timeout=32s\r\nNAME                               READY   STATUS    RESTARTS   AGE\r\npod\/cc-operator-6ffb5f5489-b6l6r   1\/1     Running   0          13h\r\npod\/connectors-0                   1\/1     Running   0          13h\r\npod\/connectors-1                   1\/1     Running   0          13h\r\npod\/controlcenter-0                1\/1     Running   0          13h\r\npod\/kafka-0                        1\/1     Running   0          13h\r\npod\/kafka-1                        1\/1     Running   0          13h\r\npod\/kafka-2                        1\/1     Running   0          13h\r\npod\/ksql-0                         1\/1     Running   0          13h\r\npod\/ksql-1                         1\/1     Running   0          13h\r\npod\/replicator-0                   1\/1     Running   0          13h\r\npod\/replicator-1                   1\/1     Running   0          13h\r\npod\/schemaregistry-0               1\/1     Running   0          13h\r\npod\/zookeeper-0                    1\/1     Running   0          13h\r\npod\/zookeeper-1                    1\/1     Running   0          13h\r\npod\/zookeeper-2                    1\/1     Running   0          13h\r\n(\u4ee5\u4e0b\u3001\u7701\u7565)\r\n<\/code><\/pre>\n<p>\u8bf7\u5c06Kafka\u670d\u52a1\u5668\u7684auto.create.topics.enable\u5c5e\u6027\u8bbe\u7f6e\u4e3atrue\u3002<\/p>\n<p>\u786e\u8ba4MySQL\u6b63\u5e38\u8fd0\u884c\u3002<\/p>\n<pre class=\"post-pre\"><code>&gt;oc get all -n shoheim\r\n\r\nI0912 23:02:28.265544   36803 request.go:621] Throttling request took 1.148324247s, request: GET:https:\/\/c100-e.jp-tok.containers.cloud.ibm.com:31330\/apis\/monitoring.operator.ibm.com\/v1alpha1?timeout=32s\r\nNAME                 READY   STATUS      RESTARTS   AGE\r\npod\/mysql-1-deploy   0\/1     Completed   0          45s\r\npod\/mysql-1-z54sl    1\/1     Running     0          38s\r\n(\u4ee5\u4e0b\u3001\u7701\u7565)\r\n<\/code><\/pre>\n<p>\u203b\u8bf7\u53c2\u8003\u4ee5\u4e0b\u5185\u5bb9\u6765\u8bbe\u7f6e\u7528\u6237\u6743\u9650\u548c\u65e5\u5fd7\u76f8\u5173\u8bbe\u7f6e\u3002<br \/>\nMySQL\u7684Debezium\u8fde\u63a5\u5668-\u8fdb\u884c\u8bbe\u7f6e<\/p>\n<p>\u5728MySQL\u4e2d\uff0c\u9700\u8981\u6784\u5efa\u4ee5\u4e0b\u6570\u636e\u5e93\u548c\u8868\u3002<\/p>\n<pre class=\"post-pre\"><code>mysql&gt; show databases;\r\n+--------------------+\r\n| Database           |\r\n+--------------------+\r\n| information_schema |\r\n| opdb               |\r\n+--------------------+\r\n\r\nmysql&gt; SHOW TABLES;\r\n+----------------+\r\n| Tables_in_opdb |\r\n+----------------+\r\n| menus          |\r\n+----------------+\r\n1 row in set (0.00 sec)\r\n\r\nmysql&gt; SELECT * from menus;\r\n+------+-----------+\r\n| id   | name      |\r\n+------+-----------+\r\n|    1 | curry     |\r\n|    2 | hamburger |\r\n+------+-----------+\r\n2 rows in set (0.00 sec)\r\n<\/code><\/pre>\n<h1>MySQL\u6e90\u8fde\u63a5\u5668\u7684\u914d\u7f6e<\/h1>\n<h2>\u5b89\u88c5MySQL Connector\u63d2\u4ef6<\/h2>\n<p>\u4f7f\u7528Confluent Hub\u5ba2\u6237\u7aef\uff08confluent-hub\u547d\u4ee4\uff09\u5c06Debezium MySQL Connector\u63d2\u4ef6\u5b89\u88c5\u5230Connectors\u7684Pod\u4e0a\u3002<\/p>\n<pre class=\"post-pre\"><code>&gt;oc exec -it connectors-0 \/bin\/bash\r\nbash-4.4$ confluent-hub install debezium\/debezium-connector-mysql:1.6.0\r\nThe component can be installed in any of the following Confluent Platform installations: \r\n  1. \/ (installed rpm\/deb package) \r\n  2. \/ (where this tool is installed) \r\nChoose one of these to continue the installation (1-2): 2\r\nDo you want to install this into \/usr\/share\/confluent-hub-components? (yN) y\r\n\r\n\r\nComponent's license: \r\nApache 2.0 \r\nhttps:\/\/github.com\/debezium\/debezium\/blob\/master\/LICENSE.txt \r\nI agree to the software license agreement (yN) y\r\n\r\nYou are about to install 'debezium-connector-mysql' from Debezium Community, as published on Confluent Hub. \r\nDo you want to continue? (yN) y\r\n\r\nDownloading component Debezium MySQL CDC Connector 1.6.0, provided by Debezium Community from Confluent Hub and installing into \/usr\/share\/confluent-hub-components \r\nDetected Worker's configs: \r\n  1. Standard: \/etc\/kafka\/connect-distributed.properties \r\n  2. Standard: \/etc\/kafka\/connect-standalone.properties \r\n  3. Standard: \/etc\/schema-registry\/connect-avro-distributed.properties \r\n  4. Standard: \/etc\/schema-registry\/connect-avro-standalone.properties \r\n  5. Used by Connect process with PID : \/opt\/confluent\/etc\/connect\/connect.properties \r\nDo you want to update all detected configs? (yN) y\r\n\r\nAdding installation directory to plugin path in the following files: \r\n  \/etc\/kafka\/connect-distributed.properties \r\n  \/etc\/kafka\/connect-standalone.properties \r\n  \/etc\/schema-registry\/connect-avro-distributed.properties \r\n  \/etc\/schema-registry\/connect-avro-standalone.properties \r\n  \/opt\/confluent\/etc\/connect\/connect.properties \r\n\r\nCompleted \r\n<\/code><\/pre>\n<p>\u5728\u8fd9\u91cc\uff0c\u5c06\u63d2\u4ef6\u5b89\u88c5\u5230\/usr\/share\/confluent-hub-components\u76ee\u5f55\u3002\u56e0\u6b64\uff0c\u5728\u8fde\u63a5\u5668Pod\u4e4b\u524d\uff0c\u914d\u7f6e\u4e86\u5c06\u4e0a\u8ff0\u76ee\u5f55\u4f5c\u4e3a\u6302\u8f7d\u70b9\u7684\u6301\u4e45\u5377\u3002<\/p>\n<p>\u786e\u8ba4\u5df2\u5b89\u88c5\u7684\u5185\u5bb9<\/p>\n<pre class=\"post-pre\"><code>bash-4.4$ cd \/usr\/share\/confluent-hub-components\r\nbash-4.4$ ls -ltr\r\ntotal 0\r\ndrwxrwxrwx. 5 1001 root 63 Oct 25 02:26 debezium-debezium-connector-mysql\r\nbash-4.4$ ls -l debezium-debezium-connector-mysql\r\ntotal 8\r\ndrwxrwxrwx. 2 1001 root   59 Oct 25 02:26 assets\r\ndrwxrwxrwx. 2 1001 root  175 Oct 25 02:26 doc\r\ndrwxrwxrwx. 2 1001 root 4096 Oct 25 02:26 lib\r\n-rw-rw-rw-. 1 1001 root 2868 Oct 25 02:26 manifest.json\r\nbash-4.4$ ls -l debezium-debezium-connector-mysql\/lib\r\ntotal 9624\r\n-rw-rw-rw-. 1 1001 root  337864 Oct 25 02:26 antlr4-runtime-4.8.jar\r\n-rw-rw-rw-. 1 1001 root   20743 Oct 25 02:26 debezium-api-1.6.0.Final.jar\r\n-rw-rw-rw-. 1 1001 root  376353 Oct 25 02:26 debezium-connector-mysql-1.6.0.Final.jar\r\n-rw-rw-rw-. 1 1001 root  866648 Oct 25 02:26 debezium-core-1.6.0.Final.jar\r\n-rw-rw-rw-. 1 1001 root 2777855 Oct 25 02:26 debezium-ddl-parser-1.6.0.Final.jar\r\n-rw-rw-rw-. 1 1001 root    4617 Oct 25 02:26 failureaccess-1.0.1.jar\r\n-rw-rw-rw-. 1 1001 root 2858426 Oct 25 02:26 guava-30.0-jre.jar\r\n-rw-rw-rw-. 1 1001 root  192762 Oct 25 02:26 mysql-binlog-connector-java-0.25.1.jar\r\n-rw-rw-rw-. 1 1001 root 2397321 Oct 25 02:26 mysql-connector-java-8.0.21.jar\r\n<\/code><\/pre>\n<p>\u91cd\u65b0\u542f\u52a8Pod\uff0c\u901a\u8fc7REST\u4ece\u672c\u5730\u673a\u5668\u68c0\u67e5\u63d2\u4ef6\u3002<\/p>\n<pre class=\"post-pre\"><code>&gt;curl -H \"Accept:application\/json\" https:\/\/connectors.test-ocp-f83035ec98caa9e1c443f354e8208d2f-0000.jp-tok.containers.appdomain.cloud:443\/connector-plugins -k |jq\r\n  % Total    % Received % Xferd  Average Speed   Time    Time     Time  Current\r\n                                 Dload  Upload   Total   Spent    Left  Speed\r\n100   597  100   597    0     0    711      0 --:--:-- --:--:-- --:--:--   710\r\n[\r\n  {\r\n    \"class\": \"io.debezium.connector.mysql.MySqlConnector\",\r\n    \"type\": \"source\",\r\n    \"version\": \"1.6.0.Final\"\r\n  },\r\n  {\r\n    \"class\": \"org.apache.kafka.connect.file.FileStreamSinkConnector\",\r\n    \"type\": \"sink\",\r\n    \"version\": \"6.1.0-ce\"\r\n  },\r\n  {\r\n    \"class\": \"org.apache.kafka.connect.file.FileStreamSourceConnector\",\r\n    \"type\": \"source\",\r\n    \"version\": \"6.1.0-ce\"\r\n  },\r\n  {\r\n    \"class\": \"org.apache.kafka.connect.mirror.MirrorCheckpointConnector\",\r\n    \"type\": \"source\",\r\n    \"version\": \"1\"\r\n  },\r\n  {\r\n    \"class\": \"org.apache.kafka.connect.mirror.MirrorHeartbeatConnector\",\r\n    \"type\": \"source\",\r\n    \"version\": \"1\"\r\n  },\r\n  {\r\n    \"class\": \"org.apache.kafka.connect.mirror.MirrorSourceConnector\",\r\n    \"type\": \"source\",\r\n    \"version\": \"1\"\r\n  }\r\n]\r\n<\/code><\/pre>\n<p>io.debezium.connector.mysql.MySqlConnector\u6b63\u5728\u663e\u793a\u3002(\u5176\u4ed6\u63d2\u4ef6\u90fd\u662f\u9ed8\u8ba4\u5b89\u88c5\u7684)<\/p>\n<div><img decoding=\"async\" class=\"post-images\" title=\"\" src=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7b53913a08637a698ea7\/25-0.png\" alt=\"Connector_2021-10-26-11-06-24.png\" \/><\/div>\n<h2>2. MySQL Source Connector\u7684\u914d\u7f6e<\/h2>\n<p>\u53ef\u4ee5\u4eceC3\u8fdb\u884c\u914d\u7f6e\uff0c\u4f46\u5728\u8fd9\u91cc\u6211\u4eec\u5c06\u4f7f\u7528\u672c\u5730\u8ba1\u7b97\u673a\u901a\u8fc7REST\u6784\u5efa\u8fde\u63a5\u5668\u3002<\/p>\n<pre class=\"post-pre\"><code>curl -i -X POST -H \"Accept:application\/json\" -H \"Content-Type:application\/json\" -k https:\/\/connectors.test-ocp-f83035ec98caa9e1c443f354e8208d2f-0000.jp-tok.containers.appdomain.cloud:443\/connectors\/ -d '{ \"name\": \"mysql-connector\", \"config\": { \"connector.class\": \"io.debezium.connector.mysql.MySqlConnector\", \"tasks.max\": \"1\", \"database.hostname\": \"172.21.17.38\", \"database.port\": \"3306\", \"database.user\": \"user\", \"database.password\": \"pass\", \"database.server.id\": \"184055\", \"database.server.name\": \"dbserver1\", \"database.include.list\": \"opdb\", \"database.history.kafka.bootstrap.servers\": \"kafka:9071\", \"database.history.kafka.topic\": \"dbhistory.opdb\", \"table.include.list\": \"opdb.menus\", \"database.history.consumer.security.protocol\": \"SASL_SSL\", \"database.history.consumer.sasl.mechanism\": \"PLAIN\", \"database.history.consumer.sasl.jaas.config\": \"org.apache.kafka.common.security.plain.PlainLoginModule required username=\\\"user\\\" password=\\\"password\\\";\", \"database.history.producer.security.protocol\": \"SASL_SSL\", \"database.history.producer.sasl.mechanism\": \"PLAIN\", \"database.history.producer.sasl.jaas.config\": \"org.apache.kafka.common.security.plain.PlainLoginModule required username=\\\"user\\\" password=\\\"password\\\";\", \"include.schema.changes\": \"true\" } }'\r\n<\/code><\/pre>\n<p>\u6574\u7406\u5e76\u663e\u793a\u6570\u636e\u90e8\u95e8<\/p>\n<pre class=\"post-pre\"><code><span class=\"p\">{<\/span>\r\n    <span class=\"nl\">\"name\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"mysql-connector\"<\/span><span class=\"p\">,<\/span>\r\n    <span class=\"nl\">\"config\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n        <span class=\"nl\">\"connector.class\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"io.debezium.connector.mysql.MySqlConnector\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"tasks.max\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"1\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"database.hostname\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"172.21.17.38\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"database.port\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"3306\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"database.user\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"user\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"database.password\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"pass\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"database.server.id\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"184055\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"database.server.name\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbserver1\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"database.include.list\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"opdb\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"database.history.kafka.bootstrap.servers\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"kafka:9071\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"database.history.kafka.topic\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbhistory.opdb\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"table.include.list\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"opdb.menus\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"database.history.consumer.security.protocol\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"SASL_SSL\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"database.history.consumer.sasl.mechanism\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"PLAIN\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"database.history.consumer.sasl.jaas.config\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"org.apache.kafka.common.security.plain.PlainLoginModule required username=<\/span><span class=\"se\">\\\"<\/span><span class=\"s2\">user<\/span><span class=\"se\">\\\"<\/span><span class=\"s2\"> password=<\/span><span class=\"se\">\\\"<\/span><span class=\"s2\">password<\/span><span class=\"se\">\\\"<\/span><span class=\"s2\">;\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"database.history.producer.security.protocol\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"SASL_SSL\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"database.history.producer.sasl.mechanism\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"PLAIN\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"database.history.producer.sasl.jaas.config\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"org.apache.kafka.common.security.plain.PlainLoginModule required username=<\/span><span class=\"se\">\\\"<\/span><span class=\"s2\">user<\/span><span class=\"se\">\\\"<\/span><span class=\"s2\"> password=<\/span><span class=\"se\">\\\"<\/span><span class=\"s2\">password<\/span><span class=\"se\">\\\"<\/span><span class=\"s2\">;\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"include.schema.changes\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"true\"<\/span>\r\n    <span class=\"p\">}<\/span>\r\n<span class=\"p\">}<\/span>\r\n<\/code><\/pre>\n<p>\u8bf7\u53c2\u8003\u4ee5\u4e0b\u5c5e\u6027\u3002<\/p>\n<p>MySQL\u8fde\u63a5\u5668\u914d\u7f6e\u793a\u4f8b<br \/>\n\u203b\u7531\u4e8e\u8fde\u63a5\u5668\u7684\u7248\u672c\u53ef\u80fd\u4f1a\u5bfc\u81f4\u5c5e\u6027\u53d1\u751f\u53d8\u5316\uff0c\u8bf7\u53c2\u8003\u60a8\u4f7f\u7528\u7684\u7248\u672c\u6587\u6863\u3002\u8fd9\u91cc\u4f7f\u7528\u7684\u662f1.6\u7248\u672c\u3002<\/p>\n<p>\u60a8\u53ef\u4ee5\u5728\u4e0a\u9762\u7684\u94fe\u63a5\u4e2d\u67e5\u770b\u57fa\u672c\u5c5e\u6027\uff0c\u4f46\u662f\u6211\u4eec\u8fd8\u6dfb\u52a0\u4e86\u7528\u4e8e\u4f7f\u7528SASL\/PLAIN\u8fde\u63a5\u5230Kafka\u670d\u52a1\u5668\u7684\u5c5e\u6027\uff08database.history.producer.xxx\u3001database.history.consumer.xxx\uff09\u3002<\/p>\n<p>Debezium MySQL\u6e90\u8fde\u63a5\u5668\u914d\u7f6e\u5c5e\u6027-\u6570\u636e\u5e93\u5386\u53f2\u53c2\u6570<\/p>\n<p>\u786e\u8ba4\u5df2\u6210\u529f\u8fd0\u884c\u6240\u6784\u5efa\u7684\u6e90\u8fde\u63a5\u5668\u3002<\/p>\n<pre class=\"post-pre\"><code>&gt;curl -H \"Accept:application\/json\" https:\/\/connectors.test-ocp-f83035ec98caa9e1c443f354e8208d2f-0000.jp-tok.containers.appdomain.cloud:443\/connectors\/mysql-connector\/status -k |jq\r\n  % Total    % Received % Xferd  Average Speed   Time    Time     Time  Current\r\n                                 Dload  Upload   Total   Spent    Left  Speed\r\n100   245  100   245    0     0    641      0 --:--:-- --:--:-- --:--:--   641\r\n{\r\n  \"name\": \"mysql-connector\",\r\n  \"connector\": {\r\n    \"state\": \"RUNNING\",\r\n    \"worker_id\": \"connectors-1.connectors.confluent-namespace.svc:9083\"\r\n  },\r\n  \"tasks\": [\r\n    {\r\n      \"id\": 0,\r\n      \"state\": \"RUNNING\",\r\n      \"worker_id\": \"connectors-1.connectors.confluent-namespace.svc:9083\"\r\n    }\r\n  ],\r\n  \"type\": \"source\"\r\n}\r\n<\/code><\/pre>\n<h1>\u786e\u8ba4\u4e3b\u9898\u4e0a\u7684\u6570\u636e<\/h1>\n<p>\u901a\u8fc7\u521b\u5efa\u7684Connector\uff0c\u786e\u8ba4MySQL\u7684\u6570\u636e\u5df2\u53d1\u9001\u5230Kafka\u7684\u4e3b\u9898\u3002<\/p>\n<p>\u9996\u5148\uff0c\u68c0\u67e5\u5728Kafka\u4e0a\u521b\u5efa\u7684\u4e3b\u9898\u3002<\/p>\n<div><img decoding=\"async\" class=\"post-images\" title=\"\" src=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7b53913a08637a698ea7\/40-0.png\" alt=\"Connector_2021-12-12-12-58-36.png\" \/><\/div>\n<p>\u6570\u636e\u5df2\u53d1\u9001\u5230odserver1.opdb.menus\u4e3b\u9898\u3002<\/p>\n<pre class=\"post-pre\"><code><span class=\"p\">[<\/span>\r\n    <span class=\"p\">{<\/span>\r\n        <span class=\"nl\">\"topic\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbserver1.opdb.menus\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"partition\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"offset\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestamp\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280629029<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestampType\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"CREATE_TIME\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"headers\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[],<\/span>\r\n        <span class=\"nl\">\"key\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"value\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n            <span class=\"nl\">\"before\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"after\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"id\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"name\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"curry\"<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"source\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"version\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"1.6.0.Final\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"connector\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"mysql\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"name\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbserver1\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"ts_ms\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280628022<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"snapshot\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"true\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"db\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"opdb\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"sequence\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"table\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"menus\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"server_id\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"gtid\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"file\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"binlog.000002\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"pos\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">3264<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"row\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"thread\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"query\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"op\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"r\"<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"ts_ms\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280628024<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"transaction\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span>\r\n        <span class=\"p\">}<\/span>\r\n    <span class=\"p\">},<\/span>\r\n    <span class=\"p\">{<\/span>\r\n        <span class=\"nl\">\"topic\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbserver1.opdb.menus\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"partition\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"offset\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestamp\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280629030<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestampType\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"CREATE_TIME\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"headers\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[],<\/span>\r\n        <span class=\"nl\">\"key\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"value\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n            <span class=\"nl\">\"before\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"after\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"id\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">2<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"name\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"hamburger\"<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"source\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"version\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"1.6.0.Final\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"connector\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"mysql\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"name\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbserver1\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"ts_ms\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280628026<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"snapshot\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"true\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"db\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"opdb\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"sequence\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"table\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"menus\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"server_id\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"gtid\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"file\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"binlog.000002\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"pos\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">3264<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"row\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"thread\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"query\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"op\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"r\"<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"ts_ms\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280628026<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"transaction\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span>\r\n        <span class=\"p\">}<\/span>\r\n    <span class=\"p\">}<\/span>\r\n<span class=\"p\">]<\/span>\r\n<\/code><\/pre>\n<p>\u5728Offset=0\u7684\u65f6\u5019\u53ef\u4ee5\u770b\u5230menus\u8868\u7684\u7b2c\u4e00\u884c\u6570\u636e\uff0c\u800c\u5728Offset=1\u7684\u65f6\u5019\u53ef\u4ee5\u770b\u5230\u7b2c\u4e8c\u884c\u7684\u6570\u636e\u3002<\/p>\n<p>\u5f53\u5411\u83dc\u5355\u8868\u4e2d\u6dfb\u52a0\u884c\u65f6\uff0c\u4e5f\u4f1a\u5411\u4e3b\u9898\u53d1\u9001\u65b0\u6570\u636e\u3002<\/p>\n<pre class=\"post-pre\"><code><span class=\"k\">INSERT<\/span> <span class=\"k\">INTO<\/span> <span class=\"n\">menus<\/span> <span class=\"p\">(<\/span><span class=\"n\">id<\/span><span class=\"p\">,<\/span> <span class=\"n\">name<\/span><span class=\"p\">)<\/span> <span class=\"k\">VALUES<\/span> <span class=\"p\">(<\/span><span class=\"mi\">3<\/span><span class=\"p\">,<\/span> <span class=\"s1\">'katsudon'<\/span><span class=\"p\">);<\/span>\r\n<\/code><\/pre>\n<pre class=\"post-pre\"><code>    <span class=\"p\">{<\/span>\r\n        <span class=\"nl\">\"topic\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbserver1.opdb.menus\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"partition\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"offset\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">2<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestamp\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280629030<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestampType\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"CREATE_TIME\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"headers\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[],<\/span>\r\n        <span class=\"nl\">\"key\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"value\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n            <span class=\"nl\">\"before\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"after\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"id\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">3<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"name\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"katsudon\"<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"source\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"version\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"1.6.0.Final\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"connector\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"mysql\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"name\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbserver1\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"ts_ms\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280628026<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"snapshot\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"true\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"db\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"opdb\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"sequence\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"table\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"menus\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"server_id\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"gtid\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"file\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"binlog.000002\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"pos\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">3264<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"row\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"thread\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"query\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"op\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"r\"<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"ts_ms\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280628026<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"transaction\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span>\r\n        <span class=\"p\">}<\/span>\r\n    <span class=\"p\">}<\/span>\r\n<\/code><\/pre>\n<p>\u5982\u679c\u66f4\u65b0\u4e86\u8868\u4e2d\u7684\u6570\u636e\uff0c\u4e0b\u9762\u7684\u6d88\u606f\u5c06\u88ab\u53d1\u9001\u5230\u4e3b\u9898\u4e2d\u3002<\/p>\n<pre class=\"post-pre\"><code><span class=\"k\">UPDATE<\/span> <span class=\"n\">menus<\/span> <span class=\"k\">SET<\/span> <span class=\"n\">name<\/span><span class=\"o\">=<\/span><span class=\"s1\">'tendon'<\/span> <span class=\"k\">WHERE<\/span> <span class=\"n\">id<\/span><span class=\"o\">=<\/span><span class=\"mi\">3<\/span><span class=\"p\">;<\/span>\r\n<\/code><\/pre>\n<pre class=\"post-pre\"><code><span class=\"p\">[<\/span>\r\n    <span class=\"p\">{<\/span>\r\n        <span class=\"nl\">\"topic\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbserver1.opdb.menus\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"partition\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"offset\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">4<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestamp\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639530256773<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestampType\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"CREATE_TIME\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"headers\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[],<\/span>\r\n        <span class=\"nl\">\"key\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"value\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n            <span class=\"nl\">\"before\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"id\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">3<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"name\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"katsudon\"<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"after\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"id\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">3<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"name\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"tendon\"<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"source\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"version\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"1.6.0.Final\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"connector\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"mysql\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"name\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbserver1\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"ts_ms\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639530256000<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"snapshot\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"false\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"db\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"opdb\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"sequence\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"table\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"menus\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"server_id\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"gtid\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"file\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"binlog.000002\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"pos\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">3486<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"row\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"thread\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"query\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"op\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"u\"<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"ts_ms\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639530256515<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"transaction\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span>\r\n        <span class=\"p\">}<\/span>\r\n    <span class=\"p\">}<\/span>\r\n<span class=\"p\">]<\/span>\r\n<\/code><\/pre>\n<p>\u5728before\u4e2d\u5b58\u50a8\u7740\u66f4\u65b0\u524d\u7684\u6570\u636e\uff0c\u5728after\u4e2d\u5b58\u50a8\u7740\u66f4\u65b0\u540e\u7684\u6570\u636e\u3002<\/p>\n<p>\u5982\u679c\u662f\u5220\u9664\u7684\u60c5\u51b5\uff0c\u8bf7\u53c2\u8003\u4ee5\u4e0b\u5185\u5bb9\u3002<\/p>\n<pre class=\"post-pre\"><code><span class=\"k\">DELETE<\/span> <span class=\"k\">FROM<\/span> <span class=\"n\">menus<\/span> <span class=\"k\">WHERE<\/span> <span class=\"n\">id<\/span><span class=\"o\">=<\/span><span class=\"mi\">4<\/span><span class=\"p\">;<\/span>\r\n<\/code><\/pre>\n<pre class=\"post-pre\"><code><span class=\"p\">[<\/span>\r\n    <span class=\"p\">{<\/span>\r\n        <span class=\"nl\">\"topic\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbserver1.opdb.menus\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"partition\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"offset\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">5<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestamp\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639530687264<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestampType\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"CREATE_TIME\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"headers\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[],<\/span>\r\n        <span class=\"nl\">\"key\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"value\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n            <span class=\"nl\">\"before\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"id\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">4<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"name\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"gyoza\"<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"after\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"source\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"version\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"1.6.0.Final\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"connector\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"mysql\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"name\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbserver1\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"ts_ms\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639530687000<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"snapshot\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"false\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"db\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"opdb\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"sequence\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"table\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"menus\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"server_id\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"gtid\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"file\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"binlog.000002\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"pos\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">3794<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"row\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"thread\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"query\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"op\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"d\"<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"ts_ms\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639530687221<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"transaction\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span>\r\n        <span class=\"p\">}<\/span>\r\n    <span class=\"p\">}<\/span>\r\n<span class=\"p\">]<\/span>\r\n<\/code><\/pre>\n<p>\u4ee5\u4e0b\u7684\u6d88\u606f\u50a8\u5b58\u5728Connector\u6307\u5b9a\u7684database.history.kafka.topic\u5c5e\u6027\u6240\u5bf9\u5e94\u7684dbhistory.opdb\u4e3b\u9898\u4e2d\u3002<br \/>\n\u8fd9\u4e2a\u4e3b\u9898\u7528\u4e8eConnector\u5b58\u50a8\u6570\u636e\u5e93\u7684\u6a21\u5f0f\u5386\u53f2\u8bb0\u5f55\u3002<\/p>\n<pre class=\"post-pre\"><code><span class=\"p\">[<\/span>\r\n    <span class=\"p\">{<\/span>\r\n        <span class=\"nl\">\"topic\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbhistory.opdb\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"partition\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"offset\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestamp\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280627942<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestampType\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"CREATE_TIME\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"headers\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[],<\/span>\r\n        <span class=\"nl\">\"key\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"value\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n            <span class=\"nl\">\"source\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"server\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbserver1\"<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"position\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"ts_sec\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280627<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"file\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"binlog.000002\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"pos\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">3264<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"snapshot\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">true<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"databaseName\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"\"<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"ddl\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"SET character_set_server=utf8mb4, collation_server=utf8mb4_0900_ai_ci\"<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"tableChanges\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[]<\/span>\r\n        <span class=\"p\">}<\/span>\r\n    <span class=\"p\">},<\/span>\r\n    <span class=\"p\">{<\/span>\r\n        <span class=\"nl\">\"topic\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbhistory.opdb\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"partition\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"offset\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestamp\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280627970<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestampType\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"CREATE_TIME\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"headers\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[],<\/span>\r\n        <span class=\"nl\">\"key\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"value\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n            <span class=\"nl\">\"source\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"server\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbserver1\"<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"position\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"ts_sec\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280627<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"file\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"binlog.000002\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"pos\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">3264<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"snapshot\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">true<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"databaseName\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"opdb\"<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"ddl\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"DROP TABLE IF EXISTS `opdb`.`menus`\"<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"tableChanges\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[]<\/span>\r\n        <span class=\"p\">}<\/span>\r\n    <span class=\"p\">},<\/span>\r\n    <span class=\"p\">{<\/span>\r\n        <span class=\"nl\">\"topic\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbhistory.opdb\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"partition\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"offset\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">2<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestamp\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280627973<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestampType\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"CREATE_TIME\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"headers\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[],<\/span>\r\n        <span class=\"nl\">\"key\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"value\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n            <span class=\"nl\">\"source\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"server\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbserver1\"<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"position\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"ts_sec\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280627<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"file\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"binlog.000002\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"pos\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">3264<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"snapshot\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">true<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"databaseName\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"opdb\"<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"ddl\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"DROP DATABASE IF EXISTS `opdb`\"<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"tableChanges\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[]<\/span>\r\n        <span class=\"p\">}<\/span>\r\n    <span class=\"p\">},<\/span>\r\n    <span class=\"p\">{<\/span>\r\n        <span class=\"nl\">\"topic\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbhistory.opdb\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"partition\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"offset\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">3<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestamp\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280627975<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestampType\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"CREATE_TIME\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"headers\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[],<\/span>\r\n        <span class=\"nl\">\"key\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"value\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n            <span class=\"nl\">\"source\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"server\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbserver1\"<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"position\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"ts_sec\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280627<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"file\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"binlog.000002\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"pos\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">3264<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"snapshot\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">true<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"databaseName\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"opdb\"<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"ddl\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"CREATE DATABASE `opdb` CHARSET utf8mb4 COLLATE utf8mb4_0900_ai_ci\"<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"tableChanges\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[]<\/span>\r\n        <span class=\"p\">}<\/span>\r\n    <span class=\"p\">},<\/span>\r\n    <span class=\"p\">{<\/span>\r\n        <span class=\"nl\">\"topic\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbhistory.opdb\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"partition\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"offset\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">4<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestamp\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280627981<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestampType\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"CREATE_TIME\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"headers\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[],<\/span>\r\n        <span class=\"nl\">\"key\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"value\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n            <span class=\"nl\">\"source\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"server\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbserver1\"<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"position\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"ts_sec\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280627<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"file\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"binlog.000002\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"pos\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">3264<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"snapshot\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">true<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"databaseName\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"opdb\"<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"ddl\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"USE `opdb`\"<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"tableChanges\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[]<\/span>\r\n        <span class=\"p\">}<\/span>\r\n    <span class=\"p\">},<\/span>\r\n    <span class=\"p\">{<\/span>\r\n        <span class=\"nl\">\"topic\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbhistory.opdb\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"partition\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">0<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"offset\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">5<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestamp\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280627998<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"timestampType\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"CREATE_TIME\"<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"headers\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[],<\/span>\r\n        <span class=\"nl\">\"key\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"nl\">\"value\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n            <span class=\"nl\">\"source\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"server\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"dbserver1\"<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"position\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                <span class=\"nl\">\"ts_sec\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1639280627<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"file\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"binlog.000002\"<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"pos\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">3264<\/span><span class=\"p\">,<\/span>\r\n                <span class=\"nl\">\"snapshot\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">true<\/span>\r\n            <span class=\"p\">},<\/span>\r\n            <span class=\"nl\">\"databaseName\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"opdb\"<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"ddl\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"CREATE TABLE `menus` (<\/span><span class=\"se\">\\n<\/span><span class=\"s2\">  `id` int DEFAULT NULL,<\/span><span class=\"se\">\\n<\/span><span class=\"s2\">  `name` varchar(100) DEFAULT NULL<\/span><span class=\"se\">\\n<\/span><span class=\"s2\">) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci\"<\/span><span class=\"p\">,<\/span>\r\n            <span class=\"nl\">\"tableChanges\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[<\/span>\r\n                <span class=\"p\">{<\/span>\r\n                    <span class=\"nl\">\"type\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"CREATE\"<\/span><span class=\"p\">,<\/span>\r\n                    <span class=\"nl\">\"id\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"<\/span><span class=\"se\">\\\"<\/span><span class=\"s2\">opdb<\/span><span class=\"se\">\\\"<\/span><span class=\"s2\">.<\/span><span class=\"se\">\\\"<\/span><span class=\"s2\">menus<\/span><span class=\"se\">\\\"<\/span><span class=\"s2\">\"<\/span><span class=\"p\">,<\/span>\r\n                    <span class=\"nl\">\"table\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n                        <span class=\"nl\">\"defaultCharsetName\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"utf8mb4\"<\/span><span class=\"p\">,<\/span>\r\n                        <span class=\"nl\">\"primaryKeyColumnNames\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[],<\/span>\r\n                        <span class=\"nl\">\"columns\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">[<\/span>\r\n                            <span class=\"p\">{<\/span>\r\n                                <span class=\"nl\">\"name\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"id\"<\/span><span class=\"p\">,<\/span>\r\n                                <span class=\"nl\">\"jdbcType\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">4<\/span><span class=\"p\">,<\/span>\r\n                                <span class=\"nl\">\"typeName\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"INT\"<\/span><span class=\"p\">,<\/span>\r\n                                <span class=\"nl\">\"typeExpression\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"INT\"<\/span><span class=\"p\">,<\/span>\r\n                                <span class=\"nl\">\"charsetName\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">null<\/span><span class=\"p\">,<\/span>\r\n                                <span class=\"nl\">\"position\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1<\/span><span class=\"p\">,<\/span>\r\n                                <span class=\"nl\">\"optional\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">true<\/span><span class=\"p\">,<\/span>\r\n                                <span class=\"nl\">\"autoIncremented\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">false<\/span><span class=\"p\">,<\/span>\r\n                                <span class=\"nl\">\"generated\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">false<\/span>\r\n                            <span class=\"p\">},<\/span>\r\n                            <span class=\"p\">{<\/span>\r\n                                <span class=\"nl\">\"name\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"name\"<\/span><span class=\"p\">,<\/span>\r\n                                <span class=\"nl\">\"jdbcType\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">12<\/span><span class=\"p\">,<\/span>\r\n                                <span class=\"nl\">\"typeName\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"VARCHAR\"<\/span><span class=\"p\">,<\/span>\r\n                                <span class=\"nl\">\"typeExpression\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"VARCHAR\"<\/span><span class=\"p\">,<\/span>\r\n                                <span class=\"nl\">\"charsetName\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"utf8mb4\"<\/span><span class=\"p\">,<\/span>\r\n                                <span class=\"nl\">\"length\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">100<\/span><span class=\"p\">,<\/span>\r\n                                <span class=\"nl\">\"position\"<\/span><span class=\"p\">:<\/span> <span class=\"mi\">2<\/span><span class=\"p\">,<\/span>\r\n                                <span class=\"nl\">\"optional\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">true<\/span><span class=\"p\">,<\/span>\r\n                                <span class=\"nl\">\"autoIncremented\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">false<\/span><span class=\"p\">,<\/span>\r\n                                <span class=\"nl\">\"generated\"<\/span><span class=\"p\">:<\/span> <span class=\"kc\">false<\/span>\r\n                            <span class=\"p\">}<\/span>\r\n                        <span class=\"p\">]<\/span>\r\n                    <span class=\"p\">}<\/span>\r\n                <span class=\"p\">}<\/span>\r\n            <span class=\"p\">]<\/span>\r\n        <span class=\"p\">}<\/span>\r\n    <span class=\"p\">}<\/span>\r\n<span class=\"p\">]<\/span>\r\n<\/code><\/pre>\n<h1>\u6700\u540e<\/h1>\n<p>\u672c\u6765\u8a08\u7b97\u9700\u8981\u69cb\u5efaSink Connector\u5e76\u4e14\u5c07\u6578\u64da\u5eab\u8907\u88fd\u5230\u5176\u4ed6\u5730\u65b9\uff0c\u4f46\u7531\u65bcOCP\u74b0\u5883\u4e0d\u53ef\u7528\u7684\u5404\u7a2e\u60c5\u6cc1\uff0c\u6240\u4ee5\u6211\u5011\u5c07\u5728OCP\u74b0\u5883\u6062\u5fa9\u5f8c\u91cd\u65b0\u958b\u59cb\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"<p>\u9996\u5148 \u8ba9\u6211\u4eec\u4f7f\u7528Debezium\u7684MySQL Source Connector\u5728OpenShift\u4e0a\u914d\u7f6e\u7684Co [&hellip;]<\/p>\n","protected":false},"author":9,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-46910","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"<!-- This site is optimized with the Yoast SEO Premium plugin v21.5 (Yoast SEO v21.5) - https:\/\/yoast.com\/wordpress\/plugins\/seo\/ -->\n<title>\u5c1d\u8bd5\u5728OpenShift\u4e0a\u4f7f\u7528Debezium\u8fde\u63a5\u5668\u5c06\u914d\u7f6e\u7684Confluent Platform\u548cMySQL\u8fdb\u884c\u96c6\u6210 - Blog - Silicon Cloud<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.silicloud.com\/zh\/blog\/\u5c1d\u8bd5\u5728openshift\u4e0a\u4f7f\u7528debezium\u8fde\u63a5\u5668\u5c06\u914d\u7f6e\u7684confluent-platform\u548cmysql\u8fdb\u884c\u96c6\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u5c1d\u8bd5\u5728OpenShift\u4e0a\u4f7f\u7528Debezium\u8fde\u63a5\u5668\u5c06\u914d\u7f6e\u7684Confluent Platform\u548cMySQL\u8fdb\u884c\u96c6\u6210\" \/>\n<meta property=\"og:description\" content=\"\u9996\u5148 \u8ba9\u6211\u4eec\u4f7f\u7528Debezium\u7684MySQL Source Connector\u5728OpenShift\u4e0a\u914d\u7f6e\u7684Co [&hellip;]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/\u5c1d\u8bd5\u5728openshift\u4e0a\u4f7f\u7528debezium\u8fde\u63a5\u5668\u5c06\u914d\u7f6e\u7684confluent-platform\u548cmysql\u8fdb\u884c\u96c6\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2023-08-28T13:37:36+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-04-30T07:36:10+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7b53913a08637a698ea7\/25-0.png\" \/>\n<meta name=\"author\" content=\"\u6e05, \u626c\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u6e05, \u626c\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"8 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%b0%9d%e8%af%95%e5%9c%a8openshift%e4%b8%8a%e4%bd%bf%e7%94%a8debezium%e8%bf%9e%e6%8e%a5%e5%99%a8%e5%b0%86%e9%85%8d%e7%bd%ae%e7%9a%84confluent-platform%e5%92%8cmysql%e8%bf%9b%e8%a1%8c%e9%9b%86\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%b0%9d%e8%af%95%e5%9c%a8openshift%e4%b8%8a%e4%bd%bf%e7%94%a8debezium%e8%bf%9e%e6%8e%a5%e5%99%a8%e5%b0%86%e9%85%8d%e7%bd%ae%e7%9a%84confluent-platform%e5%92%8cmysql%e8%bf%9b%e8%a1%8c%e9%9b%86\/\",\"name\":\"\u5c1d\u8bd5\u5728OpenShift\u4e0a\u4f7f\u7528Debezium\u8fde\u63a5\u5668\u5c06\u914d\u7f6e\u7684Confluent Platform\u548cMySQL\u8fdb\u884c\u96c6\u6210 - Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2023-08-28T13:37:36+00:00\",\"dateModified\":\"2024-04-30T07:36:10+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/cb5556d2501da73d864cac945e8d9461\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%b0%9d%e8%af%95%e5%9c%a8openshift%e4%b8%8a%e4%bd%bf%e7%94%a8debezium%e8%bf%9e%e6%8e%a5%e5%99%a8%e5%b0%86%e9%85%8d%e7%bd%ae%e7%9a%84confluent-platform%e5%92%8cmysql%e8%bf%9b%e8%a1%8c%e9%9b%86\/#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%b0%9d%e8%af%95%e5%9c%a8openshift%e4%b8%8a%e4%bd%bf%e7%94%a8debezium%e8%bf%9e%e6%8e%a5%e5%99%a8%e5%b0%86%e9%85%8d%e7%bd%ae%e7%9a%84confluent-platform%e5%92%8cmysql%e8%bf%9b%e8%a1%8c%e9%9b%86\/\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%b0%9d%e8%af%95%e5%9c%a8openshift%e4%b8%8a%e4%bd%bf%e7%94%a8debezium%e8%bf%9e%e6%8e%a5%e5%99%a8%e5%b0%86%e9%85%8d%e7%bd%ae%e7%9a%84confluent-platform%e5%92%8cmysql%e8%bf%9b%e8%a1%8c%e9%9b%86\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.silicloud.com\/zh\/blog\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u5c1d\u8bd5\u5728OpenShift\u4e0a\u4f7f\u7528Debezium\u8fde\u63a5\u5668\u5c06\u914d\u7f6e\u7684Confluent Platform\u548cMySQL\u8fdb\u884c\u96c6\u6210\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/\",\"name\":\"Blog - Silicon Cloud\",\"description\":\"\",\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/cb5556d2501da73d864cac945e8d9461\",\"name\":\"\u6e05, \u626c\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/32a4239de8ff29adace466261d309424a1e5fe9f7e3036bf89fe03f2e3dbe717?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/32a4239de8ff29adace466261d309424a1e5fe9f7e3036bf89fe03f2e3dbe717?s=96&d=mm&r=g\",\"caption\":\"\u6e05, \u626c\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/qingyang\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%b0%9d%e8%af%95%e5%9c%a8openshift%e4%b8%8a%e4%bd%bf%e7%94%a8debezium%e8%bf%9e%e6%8e%a5%e5%99%a8%e5%b0%86%e9%85%8d%e7%bd%ae%e7%9a%84confluent-platform%e5%92%8cmysql%e8%bf%9b%e8%a1%8c%e9%9b%86\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"\u5c1d\u8bd5\u5728OpenShift\u4e0a\u4f7f\u7528Debezium\u8fde\u63a5\u5668\u5c06\u914d\u7f6e\u7684Confluent Platform\u548cMySQL\u8fdb\u884c\u96c6\u6210 - Blog - Silicon Cloud","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.silicloud.com\/zh\/blog\/\u5c1d\u8bd5\u5728openshift\u4e0a\u4f7f\u7528debezium\u8fde\u63a5\u5668\u5c06\u914d\u7f6e\u7684confluent-platform\u548cmysql\u8fdb\u884c\u96c6\/","og_locale":"zh_CN","og_type":"article","og_title":"\u5c1d\u8bd5\u5728OpenShift\u4e0a\u4f7f\u7528Debezium\u8fde\u63a5\u5668\u5c06\u914d\u7f6e\u7684Confluent Platform\u548cMySQL\u8fdb\u884c\u96c6\u6210","og_description":"\u9996\u5148 \u8ba9\u6211\u4eec\u4f7f\u7528Debezium\u7684MySQL Source Connector\u5728OpenShift\u4e0a\u914d\u7f6e\u7684Co [&hellip;]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/\u5c1d\u8bd5\u5728openshift\u4e0a\u4f7f\u7528debezium\u8fde\u63a5\u5668\u5c06\u914d\u7f6e\u7684confluent-platform\u548cmysql\u8fdb\u884c\u96c6\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2023-08-28T13:37:36+00:00","article_modified_time":"2024-04-30T07:36:10+00:00","og_image":[{"url":"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7b53913a08637a698ea7\/25-0.png"}],"author":"\u6e05, \u626c","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u6e05, \u626c","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"8 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%b0%9d%e8%af%95%e5%9c%a8openshift%e4%b8%8a%e4%bd%bf%e7%94%a8debezium%e8%bf%9e%e6%8e%a5%e5%99%a8%e5%b0%86%e9%85%8d%e7%bd%ae%e7%9a%84confluent-platform%e5%92%8cmysql%e8%bf%9b%e8%a1%8c%e9%9b%86\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%b0%9d%e8%af%95%e5%9c%a8openshift%e4%b8%8a%e4%bd%bf%e7%94%a8debezium%e8%bf%9e%e6%8e%a5%e5%99%a8%e5%b0%86%e9%85%8d%e7%bd%ae%e7%9a%84confluent-platform%e5%92%8cmysql%e8%bf%9b%e8%a1%8c%e9%9b%86\/","name":"\u5c1d\u8bd5\u5728OpenShift\u4e0a\u4f7f\u7528Debezium\u8fde\u63a5\u5668\u5c06\u914d\u7f6e\u7684Confluent Platform\u548cMySQL\u8fdb\u884c\u96c6\u6210 - Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2023-08-28T13:37:36+00:00","dateModified":"2024-04-30T07:36:10+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/cb5556d2501da73d864cac945e8d9461"},"breadcrumb":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%b0%9d%e8%af%95%e5%9c%a8openshift%e4%b8%8a%e4%bd%bf%e7%94%a8debezium%e8%bf%9e%e6%8e%a5%e5%99%a8%e5%b0%86%e9%85%8d%e7%bd%ae%e7%9a%84confluent-platform%e5%92%8cmysql%e8%bf%9b%e8%a1%8c%e9%9b%86\/#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/%e5%b0%9d%e8%af%95%e5%9c%a8openshift%e4%b8%8a%e4%bd%bf%e7%94%a8debezium%e8%bf%9e%e6%8e%a5%e5%99%a8%e5%b0%86%e9%85%8d%e7%bd%ae%e7%9a%84confluent-platform%e5%92%8cmysql%e8%bf%9b%e8%a1%8c%e9%9b%86\/"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%b0%9d%e8%af%95%e5%9c%a8openshift%e4%b8%8a%e4%bd%bf%e7%94%a8debezium%e8%bf%9e%e6%8e%a5%e5%99%a8%e5%b0%86%e9%85%8d%e7%bd%ae%e7%9a%84confluent-platform%e5%92%8cmysql%e8%bf%9b%e8%a1%8c%e9%9b%86\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.silicloud.com\/zh\/blog\/"},{"@type":"ListItem","position":2,"name":"\u5c1d\u8bd5\u5728OpenShift\u4e0a\u4f7f\u7528Debezium\u8fde\u63a5\u5668\u5c06\u914d\u7f6e\u7684Confluent Platform\u548cMySQL\u8fdb\u884c\u96c6\u6210"}]},{"@type":"WebSite","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website","url":"https:\/\/www.silicloud.com\/zh\/blog\/","name":"Blog - Silicon Cloud","description":"","inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/cb5556d2501da73d864cac945e8d9461","name":"\u6e05, \u626c","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/32a4239de8ff29adace466261d309424a1e5fe9f7e3036bf89fe03f2e3dbe717?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/32a4239de8ff29adace466261d309424a1e5fe9f7e3036bf89fe03f2e3dbe717?s=96&d=mm&r=g","caption":"\u6e05, \u626c"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/qingyang\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%b0%9d%e8%af%95%e5%9c%a8openshift%e4%b8%8a%e4%bd%bf%e7%94%a8debezium%e8%bf%9e%e6%8e%a5%e5%99%a8%e5%b0%86%e9%85%8d%e7%bd%ae%e7%9a%84confluent-platform%e5%92%8cmysql%e8%bf%9b%e8%a1%8c%e9%9b%86\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46910","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/users\/9"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=46910"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46910\/revisions"}],"predecessor-version":[{"id":92764,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46910\/revisions\/92764"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=46910"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=46910"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=46910"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}