Spring Boot集成Debezium无法捕获PostgreSQL数据库变更事件

问题原因 #

控制台报错明确指出topic.prefix参数缺失或无效，这个参数是Debezium PostgreSQL连接器的必填项，用于标识数据源并生成对应的Kafka主题前缀，缺失会导致连接器初始化失败，自然无法监听数据库变更事件。

修复步骤 #

1. 检查并补充Debezium连接器配置
   在你的DebeziumConfig配置类中，找到连接器参数配置的代码块，确保添加topic.prefix参数并赋予有效取值（比如用你的应用名或数据库标识作为前缀）：

   // 示例：Debezium连接器核心配置
   Map<String, String> config = new HashMap<>();
   config.put("connector.class", "io.debezium.connector.postgresql.PostgresConnector");
   config.put("topic.prefix", "my_postgres_cdc"); // 必须添加这一行，取值自定义
   config.put("database.hostname", "localhost");
   config.put("database.port", "5432");
   config.put("database.user", "postgres");
   config.put("database.password", "postgres");
   config.put("database.dbname", "your_db_name");
   config.put("table.include.list", "public.client"); // 指定监听的表
   // 其他配置...
   

2. 重启应用验证
   重新启动Spring Boot应用，观察控制台是否还存在Connector configuration is not valid的错误。如果配置正确，连接器会正常初始化。

3. 触发数据库变更测试
   再次调用/client/add接口写入数据，此时CDCListener应该能正常捕获到数据库变更事件并输出日志。

额外注意事项 #

• 确保topic.prefix取值不能包含特殊字符（如空格、斜杠等），建议用小写字母、数字和下划线组合。
• 若使用配置文件（如application.yml）管理Debezium参数，需对应添加：

  debezium:
    connector:
      topic.prefix: my_postgres_cdc
      # 其他数据库连接参数...
  

内容的提问来源于stack exchange，提问作者Amith