2024.07纪念一 debezium ： spring-boot结合debezium

在Spring Boot项目中使用Debezium可以通过引入相关依赖并配置Debezium源实现。以下是一个基本的例子：

1. 添加Debezium和Spring Boot的依赖到你的pom.xml文件中：

<dependencies>
    <!-- Spring Boot -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter</artifactId>
    </dependency>
 
    <!-- Debezium -->
    <dependency>
        <groupId>io.debezium</groupId>
        <artifactId>debezium-connector-mysql</artifactId>
        <version>1.8.0.Final</version>
    </dependency>
 
    <!-- 数据库驱动，例如MySQL -->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.26</version>
    </dependency>
</dependencies>

2. 在application.properties或application.yml中配置Debezium源：

# application.properties
spring.application.name=debezium-demo
 
# Debezium 配置
debezium.io.kafka.bootstrap.servers=localhost:9092
debezium.io.kafka.topic=dbserver1.inventory.customers
 
# 数据库连接信息
debezium.sql.server.host=dbserver
debezium.sql.server.port=3306
debezium.sql.server.user=debeziumuser
debezium.sql.server.password=dbz
 
# 数据库信息
debezium.database.hostname=dbserver
debezium.database.server.id=184054
debezium.database.server.name=dbserver1
debezium.database.user=debeziumuser
debezium.database.password=dbz
debezium.database.dbname=inventory

3. 创建一个配置类来配置Debezium源：

import io.debezium.config.Configuration;
import io.debezium.embedded.EmbeddedEngine;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
@Configuration
public class DebeziumConfig {
 
    @Bean
    public EmbeddedEngine debeziumEngine() {
        Configuration config = Configuration.create()
                .with("name", "inventory-connector")
                .with("connector.class", "io.debezium.connector.mysql.MySqlConnector")
                // 其他Debezium配置...
                ;
 
        return EmbeddedEngine.create()
                .using(config)
                .notifyingChangeRecords(changeRecord -> {
                    // 处理变更记录
                })
                .build();
    }
}

4. 启动Spring Boot应用程序，Debezium将开始监听数据库变更事件。

确保你的数据库用户有足够的权限来连接和监听变更，并且Kafka服务器（如果你使用Kafka作为中继）是可访问的。这个例子只是一个基本的指引，实际应用中可能需要根据具体需求进行调整。