{"id":46839,"date":"2023-04-09T02:06:47","date_gmt":"2023-07-06T12:00:41","guid":{"rendered":"https:\/\/www.silicloud.com\/zh\/blog\/debezium-%e7%9b%91%e6%b5%8b%e6%95%b0%e6%8d%ae%e5%ba%93%e7%ad%89%e6%95%b0%e6%8d%ae%e6%ba%90%e7%9a%84%e6%9b%b4%e6%94%b9%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87%e6%b6%88%e8%b4%b9%e8%80%85%e6%8e%a5%e6%94%b6\/"},"modified":"2024-04-29T22:37:28","modified_gmt":"2024-04-29T14:37:28","slug":"debezium-%e7%9b%91%e6%b5%8b%e6%95%b0%e6%8d%ae%e5%ba%93%e7%ad%89%e6%95%b0%e6%8d%ae%e6%ba%90%e7%9a%84%e6%9b%b4%e6%94%b9%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87%e6%b6%88%e8%b4%b9%e8%80%85%e6%8e%a5%e6%94%b6","status":"publish","type":"post","link":"https:\/\/www.silicloud.com\/zh\/blog\/debezium-%e7%9b%91%e6%b5%8b%e6%95%b0%e6%8d%ae%e5%ba%93%e7%ad%89%e6%95%b0%e6%8d%ae%e6%ba%90%e7%9a%84%e6%9b%b4%e6%94%b9%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87%e6%b6%88%e8%b4%b9%e8%80%85%e6%8e%a5%e6%94%b6\/","title":{"rendered":"Debezium &#8211; \u76d1\u6d4b\u6570\u636e\u5e93\u7b49\u6570\u636e\u6e90\u7684\u66f4\u6539\uff0c\u5e76\u901a\u8fc7\u6d88\u8d39\u8005\u63a5\u6536"},"content":{"rendered":"<h1>\u6458\u8981<\/h1>\n<p>\u4ee5\u4e0b\u662f\u4e0a\u6b21\u7684\u5ef6\u7eed\u3002<br \/>\n\u8fd9\u6b21\u662f\u6709\u5173\u6d88\u8d39\u8005\uff08Consumer\uff09\u63a5\u6536\u53d8\u66f4\u5185\u5bb9\u5e76\u8f93\u51fa\u6d88\u606f\u7684\u7b14\u8bb0\u3002<\/p>\n<h1>docker-compose (Docker \u5408\u6210\u5de5\u5177)<\/h1>\n<p>\u7531\u4e8e\u7ecf\u5e38\u542f\u52a8\u5f88\u9ebb\u70e6\uff0c\u6240\u4ee5\u6211\u9009\u62e9\u4e86\u7528docker-compose\u3002<br \/>\n\u8fd9\u662f\u5c06\u4e0a\u4e00\u6b21\u7684\u6559\u7a0b\u4e2d\u4f7f\u7528docker run\u7684\u64cd\u4f5c\u6539\u6210\u4e86docker-compose\u7684\u6837\u5b50\u3002<\/p>\n<h3>\u7b54\u6848: \u70b9\u6570\/\u79ef\u5206<\/h3>\n<p>debezium_network \u3068\u3044\u3046\u540d\u524d\u306e Docker \u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u306b\u3059\u3079\u3066\u914d\u7f6e\u3057\u307e\u3059\u3002<br \/>\nversion \u304c\u3061\u3087\u3063\u3068\u53e4\u3044\u306e\u306f\u4f1a\u793e\u306e docker \u306e\u30d0\u30fc\u30b8\u30e7\u30f3\u304c\u3061\u3087\u3063\u3068\u53e4\u3044\u304b\u3089\u3067\u3059\u3002v3 \u3092\u4f7f\u7528\u3059\u308b\u3068 network \u5468\u308a\u306e\u66f8\u304d\u65b9\u306a\u3069\u304c\u3061\u3087\u3063\u3068\u5909\u308f\u308b\u307f\u305f\u3044\u3067\u3059\u3002<\/p>\n<pre class=\"post-pre\"><code><span class=\"na\">version<\/span><span class=\"pi\">:<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">2.4\"<\/span>\r\n<span class=\"na\">services<\/span><span class=\"pi\">:<\/span>\r\n  <span class=\"na\">zookeeper<\/span><span class=\"pi\">:<\/span>\r\n    <span class=\"na\">container_name<\/span><span class=\"pi\">:<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">zookeeper\"<\/span>\r\n    <span class=\"na\">image<\/span><span class=\"pi\">:<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">debezium\/zookeeper:1.8\"<\/span>\r\n    <span class=\"na\">networks<\/span><span class=\"pi\">:<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">debezium_network\"<\/span>\r\n    <span class=\"na\">ports<\/span><span class=\"pi\">:<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">2181:2181\"<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">2888:2888\"<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">3888:3888\"<\/span>\r\n\r\n  <span class=\"na\">kafka<\/span><span class=\"pi\">:<\/span>\r\n    <span class=\"na\">container_name<\/span><span class=\"pi\">:<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">kafka\"<\/span>\r\n    <span class=\"na\">image<\/span><span class=\"pi\">:<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">debezium\/kafka:1.8\"<\/span>\r\n    <span class=\"na\">depends_on<\/span><span class=\"pi\">:<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">zookeeper\"<\/span>\r\n    <span class=\"na\">networks<\/span><span class=\"pi\">:<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">debezium_network\"<\/span>\r\n    <span class=\"na\">ports<\/span><span class=\"pi\">:<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">9092:9092\"<\/span>\r\n    <span class=\"na\">environment<\/span><span class=\"pi\">:<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">ZOOKEEPER_CONNECT=zookeeper:2181\"<\/span>\r\n\r\n  <span class=\"na\">mysql<\/span><span class=\"pi\">:<\/span>\r\n    <span class=\"na\">container_name<\/span><span class=\"pi\">:<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">mysql\"<\/span>\r\n    <span class=\"na\">image<\/span><span class=\"pi\">:<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">debezium\/example-mysql:1.8\"<\/span>\r\n    <span class=\"na\">networks<\/span><span class=\"pi\">:<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">debezium_network\"<\/span>\r\n    <span class=\"na\">ports<\/span><span class=\"pi\">:<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">3306:3306\"<\/span>\r\n    <span class=\"na\">environment<\/span><span class=\"pi\">:<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">MYSQL_ROOT_PASSWORD=debezium\"<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">MYSQL_USER=mysqluser\"<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">MYSQL_PASSWORD=mysqlpw\"<\/span>\r\n\r\n  <span class=\"na\">connect<\/span><span class=\"pi\">:<\/span>\r\n    <span class=\"na\">container_name<\/span><span class=\"pi\">:<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">connect\"<\/span>\r\n    <span class=\"na\">image<\/span><span class=\"pi\">:<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">debezium\/connect:1.8\"<\/span>\r\n    <span class=\"na\">depends_on<\/span><span class=\"pi\">:<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">zookeeper\"<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">kafka\"<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">mysql\"<\/span>\r\n    <span class=\"na\">networks<\/span><span class=\"pi\">:<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">debezium_network\"<\/span>\r\n    <span class=\"na\">ports<\/span><span class=\"pi\">:<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">8083:8083\"<\/span>\r\n    <span class=\"na\">environment<\/span><span class=\"pi\">:<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">BOOTSTRAP_SERVERS=kafka:9092\"<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">GROUP_ID=1\"<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">CONFIG_STORAGE_TOPIC=my_connect_configs\"<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">OFFSET_STORAGE_TOPIC=my_connect_offsets\"<\/span>\r\n      <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">STATUS_STORAGE_TOPIC=my_connect_statuses\"<\/span>\r\n\r\n<span class=\"na\">networks<\/span><span class=\"pi\">:<\/span>\r\n  <span class=\"na\">default<\/span><span class=\"pi\">:<\/span>\r\n    <span class=\"na\">external<\/span><span class=\"pi\">:<\/span>\r\n      <span class=\"na\">name<\/span><span class=\"pi\">:<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">bridge\"<\/span>\r\n  <span class=\"na\">debezium_network<\/span><span class=\"pi\">:<\/span>\r\n    <span class=\"na\">name<\/span><span class=\"pi\">:<\/span> <span class=\"s\">debezium_network<\/span>\r\n    <span class=\"na\">driver<\/span><span class=\"pi\">:<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">bridge\"<\/span>\r\n<\/code><\/pre>\n<p>\u5148\u524d\u7684\u9700\u6c42\u662f\u5173\u4e8e\u5728 KafkaConnect \u542f\u52a8\u540e\u624b\u52a8\u6ce8\u518c DebeziumMySQL \u8fde\u63a5\u5668\u3002<\/p>\n<pre class=\"post-pre\"><code><span class=\"nv\">$ <\/span>curl <span class=\"nt\">-i<\/span> <span class=\"nt\">-X<\/span> POST <span class=\"nt\">-H<\/span> <span class=\"s2\">\"Accept:application\/json\"<\/span> <span class=\"nt\">-H<\/span> <span class=\"s2\">\"Content-Type:application\/json\"<\/span> localhost:8083\/connectors\/ <span class=\"nt\">-d<\/span> <span class=\"s1\">'{ \"name\": \"inventory-connector\", \"config\": { \"connector.class\": \"io.debezium.connector.mysql.MySqlConnector\", \"tasks.max\": \"1\", \"database.hostname\": \"mysql\", \"database.port\": \"3306\", \"database.user\": \"debezium\", \"database.password\": \"dbz\", \"database.server.id\": \"184054\", \"database.server.name\": \"dbserver1\", \"database.include.list\": \"inventory\", \"database.history.kafka.bootstrap.servers\": \"kafka:9092\", \"database.history.kafka.topic\": \"dbhistory.inventory\" } }'<\/span>\r\n<\/code><\/pre>\n<h4>\u96a8\u4fbf\u8aaa\u8aaa<\/h4>\n<p>\u8981\u60f3\u4e00\u6b21\u6027\u505c\u6b62\u5df2\u542f\u52a8\u7684\u5bb9\u5668\uff0c\u53ef\u4ee5\u4f7f\u7528\u6bc1\u706d\u5492\u8bed\u6765\u8f7b\u677e\u5b9e\u73b0\u3002<\/p>\n<h2>\u987e\u5ba2\u51c6\u5907<\/h2>\n<p>\u5f53\u6570\u636e\u6e90\u53d1\u751f\u53d8\u5316\u65f6\uff0cdebezium\u4f1a\u68c0\u6d4b\u5230\u5e76\u5c06\u53d8\u66f4\u5185\u5bb9\u4f5c\u4e3a\u961f\u5217\u6ce8\u518c\u5230kafka\u4e2d\u3002<br \/>\n\u5229\u7528\u6ce8\u518c\u5230\u961f\u5217\u4e2d\u7684\u5185\u5bb9\u8fdb\u884c\u67d0\u4e9b\u64cd\u4f5c\u3002<\/p>\n<p>\u8fd9\u6b21\u6211\u4eec\u5c06\u5feb\u901f\u5730\u4f7f\u7528Node.js\u521b\u5efa\u4e00\u4e2a\u5e94\u7528\u7a0b\u5e8f\uff0c\u4e00\u65e6\u6709\u961f\u5217\u88ab\u6ce8\u518c\uff0c\u5c31\u5c06\u5176\u5185\u5bb9\u663e\u793a\u5728\u63a7\u5236\u53f0\u4e0a\u3002\u6211\u4eec\u4f7f\u7528\u4e86\u4e00\u4e2a\u540d\u4e3akafka-node\u7684\u5305\u3002<\/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\">\"test-kafka-node\"<\/span><span class=\"p\">,<\/span>\r\n  <span class=\"nl\">\"version\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"1.0.0\"<\/span><span class=\"p\">,<\/span>\r\n  <span class=\"nl\">\"description\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"\"<\/span><span class=\"p\">,<\/span>\r\n  <span class=\"nl\">\"main\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"index.ts\"<\/span><span class=\"p\">,<\/span>\r\n  <span class=\"nl\">\"scripts\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n    <span class=\"nl\">\"start\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"ts-node index.ts\"<\/span>\r\n  <span class=\"p\">},<\/span>\r\n  <span class=\"nl\">\"author\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"\"<\/span><span class=\"p\">,<\/span>\r\n  <span class=\"nl\">\"license\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"ISC\"<\/span><span class=\"p\">,<\/span>\r\n  <span class=\"nl\">\"dependencies\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n    <span class=\"nl\">\"kafka-node\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"^5.0.0\"<\/span><span class=\"p\">,<\/span>\r\n    <span class=\"nl\">\"ts-node\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"^10.4.0\"<\/span>\r\n  <span class=\"p\">},<\/span>\r\n  <span class=\"nl\">\"devDependencies\"<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>\r\n    <span class=\"nl\">\"@types\/kafka-node\"<\/span><span class=\"p\">:<\/span> <span class=\"s2\">\"^3.0.0\"<\/span>\r\n  <span class=\"p\">}<\/span>\r\n<span class=\"p\">}<\/span>\r\n\r\n<\/code><\/pre>\n<pre class=\"post-pre\"><code><span class=\"k\">import<\/span> <span class=\"nx\">kafka<\/span> <span class=\"k\">from<\/span> <span class=\"dl\">\"<\/span><span class=\"s2\">kafka-node<\/span><span class=\"dl\">\"<\/span><span class=\"p\">;<\/span>\r\n\r\n<span class=\"kd\">const<\/span> <span class=\"nx\">client<\/span> <span class=\"o\">=<\/span> <span class=\"k\">new<\/span> <span class=\"nx\">kafka<\/span><span class=\"p\">.<\/span><span class=\"nx\">KafkaClient<\/span><span class=\"p\">({<\/span>\r\n  <span class=\"na\">kafkaHost<\/span><span class=\"p\">:<\/span> <span class=\"dl\">\"<\/span><span class=\"s2\">kafka:9092<\/span><span class=\"dl\">\"<\/span><span class=\"p\">,<\/span>\r\n<span class=\"p\">});<\/span>\r\n<span class=\"kd\">const<\/span> <span class=\"nx\">consumer<\/span> <span class=\"o\">=<\/span> <span class=\"k\">new<\/span> <span class=\"nx\">kafka<\/span><span class=\"p\">.<\/span><span class=\"nx\">Consumer<\/span><span class=\"p\">(<\/span>\r\n  <span class=\"nx\">client<\/span><span class=\"p\">,<\/span>\r\n  <span class=\"p\">[{<\/span> <span class=\"na\">topic<\/span><span class=\"p\">:<\/span> <span class=\"dl\">\"<\/span><span class=\"s2\">dbserver1.inventory.customers<\/span><span class=\"dl\">\"<\/span><span class=\"p\">}],<\/span><span class=\"err\">\u3000<\/span><span class=\"c1\">\/\/ \u2605customers \u30c6\u30fc\u30d6\u30eb\u306b\u5909\u66f4\u3092\u52a0\u3048\u308b\u4e88\u5b9a<\/span>\r\n  <span class=\"p\">{<\/span>\r\n    <span class=\"nl\">autoCommit<\/span><span class=\"p\">:<\/span> <span class=\"kc\">true<\/span><span class=\"p\">,<\/span>\r\n    <span class=\"nx\">fromOffset<\/span><span class=\"p\">:<\/span> <span class=\"kc\">true<\/span><span class=\"p\">,<\/span>\r\n    <span class=\"nx\">groupId<\/span><span class=\"p\">:<\/span> <span class=\"dl\">\"<\/span><span class=\"s2\">consumer1<\/span><span class=\"dl\">\"<\/span><span class=\"p\">,<\/span>\r\n  <span class=\"p\">}<\/span>\r\n<span class=\"p\">);<\/span>\r\n\r\n<span class=\"nx\">consumer<\/span><span class=\"p\">.<\/span><span class=\"nx\">on<\/span><span class=\"p\">(<\/span><span class=\"dl\">\"<\/span><span class=\"s2\">message<\/span><span class=\"dl\">\"<\/span><span class=\"p\">,<\/span> <span class=\"kd\">function<\/span> <span class=\"p\">(<\/span><span class=\"nx\">message<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>\r\n  <span class=\"nx\">console<\/span><span class=\"p\">.<\/span><span class=\"nx\">log<\/span><span class=\"p\">(<\/span><span class=\"nx\">message<\/span><span class=\"p\">);<\/span>\r\n<span class=\"p\">});<\/span>\r\n\r\n<span class=\"nx\">console<\/span><span class=\"p\">.<\/span><span class=\"nx\">log<\/span><span class=\"p\">(<\/span><span class=\"dl\">\"<\/span><span class=\"s2\">ready.<\/span><span class=\"dl\">\"<\/span><span class=\"p\">);<\/span>\r\n<\/code><\/pre>\n<p>\u6211\u4e5f\u4f1a\u521b\u5efa\u4e00\u4e2aDockerfile\u3002<br \/>\n\u8fd9\u57fa\u672c\u4e0a\u662f\u5b8c\u5168\u6284\u88ad\u81ea\u8fd9\u91cc\u7684\u3002<\/p>\n<pre class=\"post-pre\"><code><span class=\"c\"># OS: Debian Buster<\/span>\r\n<span class=\"c\"># Node.js: 14.4.0<\/span>\r\n<span class=\"k\">FROM<\/span><span class=\"s\"> node:14.4.0-buster<\/span>\r\n\r\n<span class=\"c\"># Create app directory<\/span>\r\n<span class=\"k\">WORKDIR<\/span><span class=\"s\"> \/usr\/src\/app<\/span>\r\n\r\n<span class=\"c\"># Install app dependencies (package.json and package-lock.json)<\/span>\r\n<span class=\"k\">COPY<\/span><span class=\"s\"> package*.json .\/<\/span>\r\n<span class=\"k\">RUN <\/span>npm <span class=\"nb\">install<\/span>\r\n\r\n<span class=\"c\"># Bundle app source (server.js)<\/span>\r\n<span class=\"k\">COPY<\/span><span class=\"s\"> . .<\/span>\r\n\r\n<span class=\"c\"># Listen port<\/span>\r\n<span class=\"k\">EXPOSE<\/span><span class=\"s\"> 8080<\/span>\r\n\r\n<span class=\"c\"># Run Node.js<\/span>\r\n<span class=\"k\">CMD<\/span><span class=\"s\"> [ \"npm\", \"run\", \"start\" ]<\/span>\r\n<\/code><\/pre>\n<h2>\u987e\u5ba2\u542f\u52a8<\/h2>\n<p>\u4e3a\u4e86\u5728\u540c\u4e00\u7f51\u7edc\u4e2d\u542f\u52a8\uff0c\u8bf7\u4f7f\u7528&#8211;network debezium_network\u9009\u9879\u8fdb\u884c\u6307\u5b9a\u3002<\/p>\n<pre class=\"post-pre\"><code><span class=\"nv\">$ <\/span>docker image build <span class=\"nt\">-t<\/span> test-kafka-node:latest <span class=\"nb\">.<\/span>\r\n<span class=\"nv\">$ <\/span>docker run <span class=\"nt\">-it<\/span> <span class=\"nt\">--rm<\/span> <span class=\"nt\">--name<\/span> consumer <span class=\"nt\">--network<\/span> debezium_network test-kafka-node\r\n<\/code><\/pre>\n<h4>\u505a\u51fa\u66f4\u6539<\/h4>\n<p>\u8fd9\u6b21\u6211\u4eec\u5c06\u76f4\u63a5\u8fdb\u5165MySQL\u5bb9\u5668\uff0c\u5e76\u5c1d\u8bd5\u6267\u884cUpdate\u8bed\u53e5\u3002<\/p>\n<pre class=\"post-pre\"><code><span class=\"nv\">$ <\/span>docker <span class=\"nb\">exec<\/span> <span class=\"nt\">-it<\/span> mysql bash\r\nroot@d8382f3c83e8:\/# mysql <span class=\"nt\">-uroot<\/span> <span class=\"nt\">-pdebezium<\/span>\r\nmysql: <span class=\"o\">[<\/span>Warning] Using a password on the <span class=\"nb\">command <\/span>line interface can be insecure.\r\nWelcome to the MySQL monitor.  Commands end with <span class=\"p\">;<\/span> or <span class=\"se\">\\g<\/span><span class=\"nb\">.<\/span>\r\nYour MySQL connection <span class=\"nb\">id <\/span>is 8\r\nServer version: 8.0.27 MySQL Community Server - GPL\r\n\r\nCopyright <span class=\"o\">(<\/span>c<span class=\"o\">)<\/span> 2000, 2021, Oracle and\/or its affiliates.\r\n\r\nOracle is a registered trademark of Oracle Corporation and\/or its\r\naffiliates. Other names may be trademarks of their respective\r\nowners.\r\n\r\nType <span class=\"s1\">'help;'<\/span> or <span class=\"s1\">'\\h'<\/span> <span class=\"k\">for <\/span>help. Type <span class=\"s1\">'\\c'<\/span> to clear the current input statement.\r\n\r\nmysql&gt; use inventory<span class=\"p\">;<\/span>\r\nReading table information <span class=\"k\">for <\/span>completion of table and column names\r\nYou can turn off this feature to get a quicker startup with <span class=\"nt\">-A<\/span>\r\n\r\nDatabase changed\r\nmysql&gt; UPDATE customers SET <span class=\"nv\">first_name<\/span><span class=\"o\">=<\/span><span class=\"s1\">'Anne99999'<\/span> WHERE <span class=\"nb\">id<\/span><span class=\"o\">=<\/span>1004<span class=\"p\">;<\/span>\r\nQuery OK, 1 row affected <span class=\"o\">(<\/span>0.00 sec<span class=\"o\">)<\/span>\r\nRows matched: 1  Changed: 1  Warnings: 0\r\n<\/code><\/pre>\n<p>\u5982\u679c\u5bf9\u4e0a\u8ff0\u7684customers\u8868\u8fdb\u884c\u66f4\u6539\uff0c\u90a3\u4e48<\/p>\n<ol>\n<li style=\"list-style-type: none;\">\n<ol>\u987e\u5ba2\u8868\u4f1a\u6709\u66f4\u6539<\/ol>\n<\/li>\n<\/ol>\n<p>&nbsp;<\/p>\n<ol>\n<li style=\"list-style-type: none;\">\n<ol>\u901a\u8fc7Debezium\u5c06\u961f\u5217\u6ce8\u518c\u5230Kafka\u4e2d<\/ol>\n<\/li>\n<\/ol>\n<p>&nbsp;<\/p>\n<ol>Node.js\u7684\u6d88\u8d39\u8005\u4f1a\u6355\u83b7\u8fdb\u5165Kafka\u7684\u961f\u5217\uff0c\u7136\u540e\u6267\u884cconsole.log(message)\u64cd\u4f5c\u3002<\/ol>\n<p>\u5728\u6d88\u8d39\u8005\u5bb9\u5668\u4e2d\u5b9e\u9645\u4e0a\u53ef\u4ee5\u786e\u8ba4\u6d88\u606f\u3002<br \/>\n\u7531\u4e8e\u53ef\u4ee5\u4ece\u6d88\u606f\u4e2d\u83b7\u53d6\u53d8\u66f4\u5185\u5bb9\uff0c\u56e0\u6b64\u53ef\u4ee5\u6839\u636e\u8fd9\u4e9b\u5185\u5bb9\u8c03\u7528 Lambda\uff0c\u5c06\u6570\u636e\u63d2\u5165\u5230\u8bfb\u6a21\u578b\u4e2d\uff0c\u53d1\u9001\u7535\u5b50\u90ae\u4ef6\u7b49\uff0c\u53ef\u4ee5\u8fdb\u884c\u4efb\u4f55\u5176\u4ed6\u64cd\u4f5c\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"<p>\u6458\u8981 \u4ee5\u4e0b\u662f\u4e0a\u6b21\u7684\u5ef6\u7eed\u3002 \u8fd9\u6b21\u662f\u6709\u5173\u6d88\u8d39\u8005\uff08Consumer\uff09\u63a5\u6536\u53d8\u66f4\u5185\u5bb9\u5e76\u8f93\u51fa\u6d88\u606f\u7684\u7b14\u8bb0\u3002 docker-c [&hellip;]<\/p>\n","protected":false},"author":8,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-46839","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>Debezium - \u76d1\u6d4b\u6570\u636e\u5e93\u7b49\u6570\u636e\u6e90\u7684\u66f4\u6539\uff0c\u5e76\u901a\u8fc7\u6d88\u8d39\u8005\u63a5\u6536 - 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\/debezium-\u76d1\u6d4b\u6570\u636e\u5e93\u7b49\u6570\u636e\u6e90\u7684\u66f4\u6539\uff0c\u5e76\u901a\u8fc7\u6d88\u8d39\u8005\u63a5\u6536\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"Debezium - \u76d1\u6d4b\u6570\u636e\u5e93\u7b49\u6570\u636e\u6e90\u7684\u66f4\u6539\uff0c\u5e76\u901a\u8fc7\u6d88\u8d39\u8005\u63a5\u6536\" \/>\n<meta property=\"og:description\" content=\"\u6458\u8981 \u4ee5\u4e0b\u662f\u4e0a\u6b21\u7684\u5ef6\u7eed\u3002 \u8fd9\u6b21\u662f\u6709\u5173\u6d88\u8d39\u8005\uff08Consumer\uff09\u63a5\u6536\u53d8\u66f4\u5185\u5bb9\u5e76\u8f93\u51fa\u6d88\u606f\u7684\u7b14\u8bb0\u3002 docker-c [&hellip;]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/debezium-\u76d1\u6d4b\u6570\u636e\u5e93\u7b49\u6570\u636e\u6e90\u7684\u66f4\u6539\uff0c\u5e76\u901a\u8fc7\u6d88\u8d39\u8005\u63a5\u6536\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2023-07-06T12:00:41+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-04-29T14:37:28+00:00\" \/>\n<meta name=\"author\" content=\"\u96c5, \u609f\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u96c5, \u609f\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"2 \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\/debezium-%e7%9b%91%e6%b5%8b%e6%95%b0%e6%8d%ae%e5%ba%93%e7%ad%89%e6%95%b0%e6%8d%ae%e6%ba%90%e7%9a%84%e6%9b%b4%e6%94%b9%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87%e6%b6%88%e8%b4%b9%e8%80%85%e6%8e%a5%e6%94%b6\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/debezium-%e7%9b%91%e6%b5%8b%e6%95%b0%e6%8d%ae%e5%ba%93%e7%ad%89%e6%95%b0%e6%8d%ae%e6%ba%90%e7%9a%84%e6%9b%b4%e6%94%b9%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87%e6%b6%88%e8%b4%b9%e8%80%85%e6%8e%a5%e6%94%b6\/\",\"name\":\"Debezium - \u76d1\u6d4b\u6570\u636e\u5e93\u7b49\u6570\u636e\u6e90\u7684\u66f4\u6539\uff0c\u5e76\u901a\u8fc7\u6d88\u8d39\u8005\u63a5\u6536 - Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2023-07-06T12:00:41+00:00\",\"dateModified\":\"2024-04-29T14:37:28+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/f044a4b7fa4ee2701702942002419ca6\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/debezium-%e7%9b%91%e6%b5%8b%e6%95%b0%e6%8d%ae%e5%ba%93%e7%ad%89%e6%95%b0%e6%8d%ae%e6%ba%90%e7%9a%84%e6%9b%b4%e6%94%b9%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87%e6%b6%88%e8%b4%b9%e8%80%85%e6%8e%a5%e6%94%b6\/#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/debezium-%e7%9b%91%e6%b5%8b%e6%95%b0%e6%8d%ae%e5%ba%93%e7%ad%89%e6%95%b0%e6%8d%ae%e6%ba%90%e7%9a%84%e6%9b%b4%e6%94%b9%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87%e6%b6%88%e8%b4%b9%e8%80%85%e6%8e%a5%e6%94%b6\/\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/debezium-%e7%9b%91%e6%b5%8b%e6%95%b0%e6%8d%ae%e5%ba%93%e7%ad%89%e6%95%b0%e6%8d%ae%e6%ba%90%e7%9a%84%e6%9b%b4%e6%94%b9%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87%e6%b6%88%e8%b4%b9%e8%80%85%e6%8e%a5%e6%94%b6\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.silicloud.com\/zh\/blog\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"Debezium &#8211; \u76d1\u6d4b\u6570\u636e\u5e93\u7b49\u6570\u636e\u6e90\u7684\u66f4\u6539\uff0c\u5e76\u901a\u8fc7\u6d88\u8d39\u8005\u63a5\u6536\"}]},{\"@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\/f044a4b7fa4ee2701702942002419ca6\",\"name\":\"\u96c5, \u609f\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/e71a913e914f1aad1efc391f92084294bac54bc782acd289638580134cf667a6?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/e71a913e914f1aad1efc391f92084294bac54bc782acd289638580134cf667a6?s=96&d=mm&r=g\",\"caption\":\"\u96c5, \u609f\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/yawu\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/debezium-%e7%9b%91%e6%b5%8b%e6%95%b0%e6%8d%ae%e5%ba%93%e7%ad%89%e6%95%b0%e6%8d%ae%e6%ba%90%e7%9a%84%e6%9b%b4%e6%94%b9%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87%e6%b6%88%e8%b4%b9%e8%80%85%e6%8e%a5%e6%94%b6\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"Debezium - \u76d1\u6d4b\u6570\u636e\u5e93\u7b49\u6570\u636e\u6e90\u7684\u66f4\u6539\uff0c\u5e76\u901a\u8fc7\u6d88\u8d39\u8005\u63a5\u6536 - 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\/debezium-\u76d1\u6d4b\u6570\u636e\u5e93\u7b49\u6570\u636e\u6e90\u7684\u66f4\u6539\uff0c\u5e76\u901a\u8fc7\u6d88\u8d39\u8005\u63a5\u6536\/","og_locale":"zh_CN","og_type":"article","og_title":"Debezium - \u76d1\u6d4b\u6570\u636e\u5e93\u7b49\u6570\u636e\u6e90\u7684\u66f4\u6539\uff0c\u5e76\u901a\u8fc7\u6d88\u8d39\u8005\u63a5\u6536","og_description":"\u6458\u8981 \u4ee5\u4e0b\u662f\u4e0a\u6b21\u7684\u5ef6\u7eed\u3002 \u8fd9\u6b21\u662f\u6709\u5173\u6d88\u8d39\u8005\uff08Consumer\uff09\u63a5\u6536\u53d8\u66f4\u5185\u5bb9\u5e76\u8f93\u51fa\u6d88\u606f\u7684\u7b14\u8bb0\u3002 docker-c [&hellip;]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/debezium-\u76d1\u6d4b\u6570\u636e\u5e93\u7b49\u6570\u636e\u6e90\u7684\u66f4\u6539\uff0c\u5e76\u901a\u8fc7\u6d88\u8d39\u8005\u63a5\u6536\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2023-07-06T12:00:41+00:00","article_modified_time":"2024-04-29T14:37:28+00:00","author":"\u96c5, \u609f","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u96c5, \u609f","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"2 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/debezium-%e7%9b%91%e6%b5%8b%e6%95%b0%e6%8d%ae%e5%ba%93%e7%ad%89%e6%95%b0%e6%8d%ae%e6%ba%90%e7%9a%84%e6%9b%b4%e6%94%b9%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87%e6%b6%88%e8%b4%b9%e8%80%85%e6%8e%a5%e6%94%b6\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/debezium-%e7%9b%91%e6%b5%8b%e6%95%b0%e6%8d%ae%e5%ba%93%e7%ad%89%e6%95%b0%e6%8d%ae%e6%ba%90%e7%9a%84%e6%9b%b4%e6%94%b9%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87%e6%b6%88%e8%b4%b9%e8%80%85%e6%8e%a5%e6%94%b6\/","name":"Debezium - \u76d1\u6d4b\u6570\u636e\u5e93\u7b49\u6570\u636e\u6e90\u7684\u66f4\u6539\uff0c\u5e76\u901a\u8fc7\u6d88\u8d39\u8005\u63a5\u6536 - Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2023-07-06T12:00:41+00:00","dateModified":"2024-04-29T14:37:28+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/f044a4b7fa4ee2701702942002419ca6"},"breadcrumb":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/debezium-%e7%9b%91%e6%b5%8b%e6%95%b0%e6%8d%ae%e5%ba%93%e7%ad%89%e6%95%b0%e6%8d%ae%e6%ba%90%e7%9a%84%e6%9b%b4%e6%94%b9%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87%e6%b6%88%e8%b4%b9%e8%80%85%e6%8e%a5%e6%94%b6\/#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/debezium-%e7%9b%91%e6%b5%8b%e6%95%b0%e6%8d%ae%e5%ba%93%e7%ad%89%e6%95%b0%e6%8d%ae%e6%ba%90%e7%9a%84%e6%9b%b4%e6%94%b9%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87%e6%b6%88%e8%b4%b9%e8%80%85%e6%8e%a5%e6%94%b6\/"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.silicloud.com\/zh\/blog\/debezium-%e7%9b%91%e6%b5%8b%e6%95%b0%e6%8d%ae%e5%ba%93%e7%ad%89%e6%95%b0%e6%8d%ae%e6%ba%90%e7%9a%84%e6%9b%b4%e6%94%b9%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87%e6%b6%88%e8%b4%b9%e8%80%85%e6%8e%a5%e6%94%b6\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.silicloud.com\/zh\/blog\/"},{"@type":"ListItem","position":2,"name":"Debezium &#8211; \u76d1\u6d4b\u6570\u636e\u5e93\u7b49\u6570\u636e\u6e90\u7684\u66f4\u6539\uff0c\u5e76\u901a\u8fc7\u6d88\u8d39\u8005\u63a5\u6536"}]},{"@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\/f044a4b7fa4ee2701702942002419ca6","name":"\u96c5, \u609f","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/e71a913e914f1aad1efc391f92084294bac54bc782acd289638580134cf667a6?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/e71a913e914f1aad1efc391f92084294bac54bc782acd289638580134cf667a6?s=96&d=mm&r=g","caption":"\u96c5, \u609f"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/yawu\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/debezium-%e7%9b%91%e6%b5%8b%e6%95%b0%e6%8d%ae%e5%ba%93%e7%ad%89%e6%95%b0%e6%8d%ae%e6%ba%90%e7%9a%84%e6%9b%b4%e6%94%b9%ef%bc%8c%e5%b9%b6%e9%80%9a%e8%bf%87%e6%b6%88%e8%b4%b9%e8%80%85%e6%8e%a5%e6%94%b6\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46839","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\/8"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=46839"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46839\/revisions"}],"predecessor-version":[{"id":88061,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46839\/revisions\/88061"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=46839"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=46839"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=46839"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}