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