English doc

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

• Postgresql 9.4 or later
• Kafka 0.8 or later
• ElasticSearch 5.x

amazonriver 利用pg内部的逻辑复制功能,通过在pg创建逻辑复制槽,接收数据库的逻辑变更,通过解析test_decoding特定格式的消息,得到逻辑数据

$git clone https://github.com/hellobike/amazonriver
$cd amazonriver
$go install

amazonriver -config config.json

PG数据库需要预先开启逻辑复制pg配置

amazonriver支持使用prometheus来监控同步数据状态,配置Grafana监控

同步到elasticsearch

同步到kafka

性能测试

amazonriver 使用 Apache License 2 许可