文件名称：mysql-to-kafka:POC 将 Mysql 复制更改流式传输到 Kafka 队列
文件大小：5KB
文件格式：ZIP
更新时间：2024-06-27 09:04:51
Python
Mysql-kafka-复制 演示使用 Mysql 复制协议将 Mysql 更改流式传输到 Kafka 队列，然后从这些队列中读取并在 Node.js 脚本中处理 Mysql 更改。 安装 pip install -r requirements.txt npm install 哦，去设置并让它在localhost:9092上运行。 跑步 在您的环境中设置RDS_URL ，或添加到本地.env文件并使用foreman运行。 首先，运行 Mysql 复制侦听器： python mysql-replicate-to-kafka.py 然后运行 Node.js 应用程序： node consumer.js 现在对您的数据库进行一些更改，并查看它们出现在节点应用程序的控制台中。
【文件预览】：
mysql-to-kafka-master
----.gitignore(13B)
----consumer.js(1016B)
----consumer.rb(238B)
----env.template(59B)
----package.json(495B)
----requirements.txt(43B)
----.env(100B)
----scripts()
--------magento.core_session.js(479B)
----README.md(693B)
----config.js(82B)
----mysql-replicate-to-kafka.py(3KB)
----Gemfile(15B)