Sqlstream:将MySQL复制事件流化到Apache Kafka
Sqlstream是能够作为复制者连接到MySQL服务器,将复制事件读取到Apache Kafka的topic,这些事件能够产生JSON序列号形式的map, key是产生事件的server-id。
pyr/sqlstream · GitHub可用于获得MySQL的活跃缓存更新,来自MySQL事件的物理视图。
配置简单,如下:
|
运行上面配置:
java -jar target/sqlstream-0.1.0-standalone.jar <config-file>