Debezium-Server对接PostgreSQL与Redis Stream的两类技术疑问

1. 将所有表变更统一存入单个Redis Stream #

Debezium的Redis Sink默认会为每个表创建独立的Stream，命名规则是{topic-prefix}.{schema}.{table}。要让所有表的变更都写入同一个Stream，只需在application.properties中添加Redis Sink的自定义键配置：

debezium.sink.redis.key=all_db_changes

配置完成后，所有表的变更事件都会写入名为all_db_changes的Redis Stream。之后用Python读取时，执行以下命令即可获取所有变更：

xread block 1000000 streams all_db_changes $

（注：$表示从最新的未消费位置开始读取，若要从头读取可替换为0）

2. 未使用Kafka却能配置topic.prefix的原因 #

Debezium Server是基于Kafka Connect的架构实现的，即便你没有部署Kafka集群，底层依然沿用了Kafka Connect的核心配置模型：

• topic.prefix是Debezium源连接器（此处为PostgreSQL连接器）的核心配置，用来生成变更事件的逻辑主题名，这个名称会被下游Sink组件（比如Redis）用来推导存储对象的命名规则（比如默认的Stream名称）。
• 它不属于Kafka集群的专属配置，而是Debezium源端用来标识事件来源命名空间的基础配置，因此即使不用Kafka，这个参数依然有效且必要。

关于schema级Stream读取无效的说明 #

Debezium Redis Sink默认不会生成schema级的Stream，只会为每个表创建独立的Stream，所以直接读取{topic-prefix}.{schema}是没有数据的，必须通过配置debezium.sink.redis.key指定统一的Stream名称才能实现聚合读取。

内容的提问来源于stack exchange，提问作者王抒凛