sqlstream将 SQL 复制事件流传输到 Apache Kafka

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 <config-file>