amazonriver:amazonriver是一个将postgresql的实时数据同步到es或kafka的服务 源码

亚马逊河 amazonriver是一个将postgresql的实时数据同步到es或kafka的服务 版本支持 Postgresql 9.4或更高版本 Kafka 0.8或更高版本 ElasticSearch 5.x 架构图 原理 amazonriver利用pg内部的逻辑复制功能,通过在pg创建逻辑复制槽,接收数据库的逻辑变更,通过解析test_decoding特定格式的消息,得到逻辑数据 安装使用 安装 $git clone https://github.com/hellobike/amazonriver $cd amazonriver $go install 使用 amazonriver