我正在尝试实现我自己的Kafka连接与postgres集成。我创建了一个逻辑复制槽并使用 pg_logical_slot_get_changes() 接收数据库中的任何更改。不过，我有一些担心。
如何处理我的kafka connect崩溃、wal文件不断增长并使磁盘崩溃的问题。
如何创建只对一个表而不是整个数据库进行更改的逻辑复制插槽。