Looked in the source of Materialize and it looks like this is exactly what they are doing. They are using Debezium + Kafka for receiving the WAL changes. And u

Looked in the source of Materialize and it looks like this is exactly what they are doing. They are using Debezium + Kafka for receiving the WAL changes. And using send the processed WAL offsets back using a Kafka topic to Debezium + Postges. This way they can achieve consistency