go-pq-cdc-elasticsearch streams documents from PostgreSql and writes to Elasticsearch index in near real-time. - View it on GitHub