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

How to capture Embedded-debezium database connection failures with java?

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

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

使用 CompletionCallback.

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