mypipe-example

MyPipe 示例 是一个 MySQL binlog -> Kafka 复制器。 该项目的目标是演示以下数据管道： MySQL RDS binlog -> mypipe mypipe -> 卡夫卡 用法 下面概述了如何使用这个项目。 克隆回购： cd /tmp && git clone https://github.com/sakserv/mypipe-example.git 创建 Kafka 主题（如果禁用自动创建主题） cd /tmp/mypipe-example && bash -x bin/create_kafka_topic.sh <topic> Note: MyPipe uses the following for topic name: <database>_<table>_generic 修改环境配置 cd /tmp/mypipe-example