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