Sqlstream是能够作为复制者连接到MySQL服务器，将复制事件读取到ApacheKafka的topic，这些事件能够产生JSON序列号形式的map,key是产生事件的server-id。
pyr/sqlstream·GitHub可用于获得MySQL的活跃缓存更新，来自MySQL事件的物理视图。
配置简单，如下：
mysql.host=localhostmysql.port=3306mysql.user=replicatmysql.password=replicattopic=sqlstreambootstrap.servers=localhost:9092运行上面配置：
java-jartarget/sqlstream-0.1.0-stadaloe.jar<cofig-file>
评论