用Kafka实时复制PostgreSQL里的最新数据

利用Postgres 9.4的新功能Logical Decoding,实时stream所有SQL操作到Kafka,然后下游的各种consumer从Kafka中接收。

其实就是Write-ahead logging的广义应用。