如何使用 java 捕获嵌入式 debezium 数据库连接失败？

Question

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

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

Answer 1

使用 CompletionCallback.

构建 EmbeddedEngine

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