Sqlstream：将MySQL复制事件流化到Apache Kafka

banq
Sqlstream是能够作为复制者连接到MySQL服务器，将复制事件读取到Apache Kafka的topic，这些事件能够产生JSON序列号形式的map, key是产生事件的server-id。

pyr/sqlstream · GitHub可用于获得MySQL的活跃缓存更新，来自MySQL事件的物理视图。

配置简单，如下：


mysql.host=localhost
mysql.port=3306
mysql.user=replicant
mysql.password=replicant
topic=sqlstream
bootstrap.servers=localhost:9092

运行上面配置：
java -jar target/sqlstream-0.1.0-standalone.jar