如何使用 java 捕获 Embedded-debezium 数据库连接失败？

Question

在我基于嵌入式 debezium 的 CDC 应用程序中，我想捕获数据库连接失败以自动重试连接。

有没有办法在我的程序中捕获数据库连接失败？

Answer 1

使用CompletionCallback 构建EmbeddedEngine。

EmbeddedEngine.CompletionCallback completionCallback = (success, message, error) -> {
    //Handle the error.
};
EmbeddedEngine engine = EmbeddedEngine.create()
                        .using(completionCallback)
                        ...
                        .build();