How to stream PostgreSQL CDC to Kafka and use Propel to get