File tree Expand file tree Collapse file tree
src/main/java/me/zort/sqllib/debezium Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -12,9 +12,10 @@ repositories {
1212dependencies {
1313 compileOnly ' org.projectlombok:lombok:1.18.24'
1414 implementation group : ' org.jetbrains' , name : ' annotations' , version : ' 20.1.0'
15- implementation ' io.debezium:debezium-api:2.3.0.Final'
16- implementation ' io.debezium:debezium-embedded:2.3.0.Final'
17- implementation ' io.debezium:debezium-connector-mysql:2.3.0.Final'
15+ implementation ' io.debezium:debezium-api:1.9.6.Final'
16+ implementation ' io.debezium:debezium-embedded:1.9.6.Final'
17+ implementation ' io.debezium:debezium-connector-mysql:1.9.6.Final'
18+ implementation ' com.google.guava:guava:31.0-jre'
1819 implementation project(' :api' )
1920 implementation project(' :core' )
2021 annotationProcessor ' org.projectlombok:lombok:1.18.24'
Original file line number Diff line number Diff line change 11package me .zort .sqllib .debezium ;
22
3+ import com .google .common .annotations .Beta ;
34import io .debezium .config .Configuration ;
45import io .debezium .engine .ChangeEvent ;
56import io .debezium .engine .DebeziumEngine ;
1415import java .util .concurrent .Executors ;
1516import java .util .function .Function ;
1617
18+ @ Beta
1719public final class ASQLDebeziumService implements DebeziumEngine .ChangeConsumer <ChangeEvent <String , String >> {
1820
1921 public static @ NotNull Builder configure (SQLDatabaseConnection connection ) {
You can’t perform that action at this time.
0 commit comments